Java线程--BlockingQueue使用
内容导读
互联网集市收集整理的这篇技术教程文章主要介绍了Java线程--BlockingQueue使用，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含2087字，纯文字阅读大概需要3分钟。
内容图文
原创：转载需注明原创地址 https://www.cnblogs.com/fanerwei222/p/11871704.html
Java线程--BlockingQueue使用
阻塞队列就是内容满了之后, 就开始阻塞, 直到有消费者消费了东西之后才又开始生产, 看代码:
package
concurrent.blockingqueue;
import
java.util.concurrent.BlockingQueue;
import
java.util.concurrent.atomic.AtomicInteger;
/**
* 生产者
*/
public
class Producer implements Runnable {
/**
* 计数器
*/privatestatic AtomicInteger k = new AtomicInteger(0);
BlockingQueue queue;
public Producer(BlockingQueue queue) {
this.queue = queue;
}
@Override
publicvoid run() {
while (true) {
try {
/**
* 把生产出来的东西丢进队列中去
*/
queue.put(produce());
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
/**
* 生产东西, 然后返回出去
* @return
* @throws InterruptedException
*/private AtomicInteger produce() throws InterruptedException {
k.addAndGet(1);
System.out.println("生产者开始生产东西了... " + k);
return k;
}
}
package
concurrent.blockingqueue;
import
java.util.concurrent.BlockingQueue;
/**
* 消费者
*/
public
class Consumer implements Runnable {
BlockingQueue queue;
public Consumer(BlockingQueue queue){
this.queue = queue;
}
@Override
publicvoid run() {
while (true) {
try {
/**
* 延迟3秒再从队列中取出,
* 这样就可以看到生产队列生产满了之后就停止生产,
* 直到消费者消费了之后再继续生产
*/
Thread.sleep(3000);
consume(queue.take());
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
/**
* 消费东西
* @param o
*/void consume(Object o){
System.out.println("消费者开始消费东西了.... " + o);
}
}
package
concurrent.blockingqueue;
import
java.util.concurrent.ArrayBlockingQueue;
import
java.util.concurrent.BlockingQueue;
/**
* main 测试类
*/
public
class
MainTest {
public
static
void
main(String[] args) {
/**
* 搞一个阻塞队列容量为3, 当超过容量就开始堵塞
*/
BlockingQueue queue = new ArrayBlockingQueue(3);
new Thread(new Producer(queue)).start();
new Thread(new Consumer(queue)).start();
}
}
看打印结果:
生产者开始生产东西了... 1 生产者开始生产东西了... 2 生产者开始生产东西了... 3 生产者开始生产东西了... 4 消费者开始消费东西了.... 4 生产者开始生产东西了... 5 消费者开始消费东西了.... 5 生产者开始生产东西了... 6 消费者开始消费东西了.... 6 生产者开始生产东西了... 7 消费者开始消费东西了.... 7 生产者开始生产东西了... 8 消费者开始消费东西了.... 8 生产者开始生产东西了... 9 消费者开始消费东西了.... 9 生产者开始生产东西了... 10
这个结果很明显了.
原文：https://www.cnblogs.com/fanerwei222/p/11871704.html
内容总结
以上是互联网集市为您收集整理的Java线程--BlockingQueue使用全部内容，希望文章能够帮你解决Java线程--BlockingQueue使用所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。
内容备注
版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。
内容手机端
扫描二维码推送至手机访问。
来源：【匿名】