生产消费者模式实现方式和线程安全问题代码示例

import java.util.concurrent.BlockingQueue;
public class Producer implements Runnable{
	private final BlockingQueue blockingQueue;
	//设置队列缓存的大小。生产过程中超过这个大小就暂时停止生产
	private final int QUEUE_SIZE = 10;
	public Producer(BlockingQueue blockingQueue){
		this.blockingQueue = blockingQueue;
	}
	int task = 1;
	@Override
	  public void run() {
		while(true){
			try {
				System.out.println("正在生产：" + task);
				//将生产出来的产品放在队列缓存中
				blockingQueue.put(task);
				++task;
				//让其停止一会，便于查看效果
				Thread.sleep(1000);
			}
			catch (InterruptedException e) {
				e.printStackTrace();
			}
		}
	}
}

import java.util.concurrent.BlockingQueue;
//消费者
public class Consumer implements Runnable{
	private final BlockingQueue blockingQueue;
	public Consumer(BlockingQueue blockingQueue){
		this.blockingQueue = blockingQueue;
	}
	@Override
	  public void run() {
		//只要阻塞队列中有任务，就一直去消费
		while(true){
			try {
				System.out.println("正在消费： " + blockingQueue.take());
				//让其停止一会，便于查看效果
				Thread.sleep(2000);
			}
			catch (InterruptedException e) {
				e.printStackTrace();
			}
		}
	}
}

import java.util.concurrent.BlockingQueue;
import java.util.concurrent.LinkedBlockingQueue;
/**
 * 生产者消费者模式
 * 使用阻塞队列BlockingQueue
 * @author wanggenshen
 *
 */
public class TestConPro {
	public static void main(String[] args){
		BlockingQueue blockingQueue = new LinkedBlockingQueue(5);
		Producer p = new Producer(blockingQueue);
		Consumer c = new Consumer(blockingQueue);
		Thread tp = new Thread(p);
		Thread tc= new Thread(c);
		tp.start();
		tc.start();
	}
}

public static void main(String[] args){
	BlockingQueue blockingQueue = new ArrayBlockingQueue(10);
	Producer p = new Producer(blockingQueue);
	Consumer c = new Consumer(blockingQueue);
	Thread tp = new Thread(p);
	Thread tc= new Thread(c);
	tp.start();
	tc.start();
}