多线程模拟生产者消费者示例之BlockQuue
Posted z-qinfeng
tags:
篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了多线程模拟生产者消费者示例之BlockQuue相关的知识，希望对你有一定的参考价值。
public class Test {
public static void main(String[] args){
//创建一个阻塞队列,边界为1
BlockingQueue<String> queue = new ArrayBlockingQueue<String>(1);
new Thread(new PThread(queue)).start();
new Thread(new CThread(queue)).start();
}
}
/**
* 生产者
*/
class PThread implements Runnable {
private BlockingQueue<String> queue;
private AtomicInteger count = new AtomicInteger();
public PThread(BlockingQueue<String> queue) {
this.queue = queue;
}
@Override
public void run() {
while (true) {
String data = count.getAndIncrement() + "";
System.out.println("生产数据:"+data);
try {
queue.put(data);
Thread.sleep(2000);//sleep,便于观察
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
}
/**
* 消费者
*/
class CThread implements Runnable {
private BlockingQueue<String> queue;
public CThread(BlockingQueue<String> queue) {
this.queue = queue;
}
@Override
public void run() {
while (true) {
try {
String data = queue.take();
System.out.println("消费数据:"+data);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
}
因为ArrayBlockingQueue是一个阻塞的有界队列,可以直接使用它.
以上是关于多线程模拟生产者消费者示例之BlockQuue的主要内容，如果未能解决你的问题，请参考以下文章