多线程间通信：多生产者-多消费者实例

基于java的多线程编程必然躲不掉线程间通信这一步，因为java不像其他语言一般可以轻松的设置监听，所以我们多才用一些替代的办法，基于阻塞的生产者消费者模型就是一个很好的解决方案。

网上关于生产者消费者的例子并不少见，不过生产者或者消费者不只一个时，这个模型又有了新的变化。先上代码：

public class Test {
	public static void main(String[] args) {
		BlockingQueue<Integer> queue = new ArrayBlockingQueue<Integer>(10);
		P p1 = new P(queue, "1");
		P p2 = new P(queue, "2");
		C c1 = new C(queue, "1");
		C c2 = new C(queue, "2");
		p1.start();
		p2.start();
		c1.start();
		c2.start();
	}
}

以上为主程序

public class P extends Thread {
	String name;
	Logger logger = LoggerFactory.initLogger();
	BlockingQueue<Integer> queue;

	public P(BlockingQueue<Integer> queue, String name) {
		this.queue = queue;
		this.name = name;
	}

	@Override
	public void run() {
		// TODO Auto-generated method stub
		int i = 0;
		while (i++ < 100) {
			try {
				queue.put(i);
				logger.info(name + "生产:" + i);
			} catch (InterruptedException e) {
				// TODO Auto-generated catch block
				Thread.currentThread().interrupt();
			}
		}
	}
}

此为生产者

public class C extends Thread {
	String name;
	Logger logger = LoggerFactory.initLogger();

	P p = null;
	BlockingQueue<Integer> queue;

	public C(BlockingQueue<Integer> queue, String name) {
		this.queue = queue;
		this.name = name;
	}

	@Override
	public void run() {
		// TODO Auto-generated method stub
		while (true) {
			try {
				int temp = (Integer) queue.take();
				logger.info(name + "消费:" + temp);
			} catch (InterruptedException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
		}
	}
}

此为消费者

其中需要log4j，用来打印输出观察生产消费的过程。

实际上我利用了BlockingQueue来做线程间通信的缓冲区，这是一个阻塞的队列，take方法和put方法非常适合多生产者多消费者模型。

附上文章中提到的简单程序，供参考。

评论

1 楼 sw1982 2010-05-06  

...楼上介绍的是APIdoc文档还是？