阻塞队列实现生产者消费者模式

阻塞队列的特点：当队列元素已满的时候，阻塞插入操作；

                        当队列元素为空的时候，阻塞获取操作；

生产者线程：Producer 

package test7;

import java.util.concurrent.BlockingQueue;

public class Producer implements Runnable{

    private final BlockingQueue queue;
    public Producer(BlockingQueue queue){
        this.queue=queue;
    }
    @Override
    public void run() {
        for(int i=1;i<5;i++){
            try {
                System.out.println("正在生产第-"+i+"-个产品");
                queue.put(i);
            } catch (InterruptedException ex) {
                ex.printStackTrace();
            }
        }
    }

}

消费者线程：Consumer

package test7;

import java.util.concurrent.BlockingQueue;

public class Consumer implements Runnable{

    private final BlockingQueue queue;
    public Consumer(BlockingQueue queue){
        this.queue=queue;
    }
    @Override
    public void run() {
        while(true){
            try {
                System.out.println("正在消费第-"+queue.take()+"-个产品");
            } catch (InterruptedException ex) {
                ex.printStackTrace();
            }
        }
    }

}

运行：

package test7;

import java.util.concurrent.BlockingQueue;
import java.util.concurrent.LinkedBlockingQueue;

public class Run {

    public static void main(String[] args) {
        BlockingQueue queue = new LinkedBlockingQueue();
        Producer p=new Producer(queue);
        Consumer c=new Consumer(queue);
        
        Thread  productThread =new Thread(p);
        Thread  consumeThread =new Thread(c);
        productThread.start();
        consumeThread.start();
    }
}

结果：

正在生产第-1-个产品
正在生产第-2-个产品
正在生产第-3-个产品
正在消费第-1-个产品
正在消费第-2-个产品
正在消费第-3-个产品
正在生产第-4-个产品
正在消费第-4-个产品