BlockingQueue

BlockingQueue实现的生产者消费者模式：10个线程生产 1个线程消费

 

package com.jerry.concurrency;

import java.util.concurrent.BlockingQueue;


import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.LinkedBlockingQueue;


public class TestBlockingQueue {
public static void main(String[] args) {
ExecutorService 生产者 =Executors.newCachedThreadPool();
ExecutorService 消费者=Executors.newCachedThreadPool();
final BlockingQueue<String> 队列 = new LinkedBlockingQueue<String>(3);
for(int i=0;i<=10;i++){
生产者.submit(new Runnable() {
@Override
public void run() {
Double d = Math.random()*1000;
try {
队列.put(d.toString());
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println("线程"+Thread.currentThread().getName()+"放入了："+d);

}
});
}

消费者.submit(new Runnable() {
@Override
public void run() {
try {
while (true) {
Thread.sleep((int) (Math.random() * 1000));
if(队列.isEmpty())
break;
String str = 队列.take();
System.out.println("线程"+Thread.currentThread().getName()+"取出了："+str);
}
} catch (Exception e) {
e.printStackTrace();
}


}
});

}


}