生产者代码:
/**
* 生产者
*/
public class Producer implements Runnable{
private BlockingQueue<String> queue;
private List<String> list;
public volatile boolean isRunning = true;//生产者的运行状态
/**
* 重写构造方法
*/
public Producer(BlockingQueue<String> queue,List<String> list){
this.queue=queue;
this.list=list;
}
@Override
public void run() {
for(int i=0;i<this.list.size();i++){
this.queue.add(this.list.get(i));
}
this.isRunning=false;//当把数据全部放到队列后,修改生产者的运行状态
}
}/**
* 生产者
*/
public clas