阅读背景:

java使用BlockingQueue实现生产者、消费者业务

来源:互联网 

生产者代码:

 

/**
 * 生产者
 */
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



你的当前访问异常,请进行认证后继续阅读剩余内容。

分享到: