生产者消费者模型(多个生产者和多个消费者)JDK1.5之前实现版

生产者消费者模型(多个生产者和多个消费者)JDK1.5之前实现版

场景描述

代码展示

/**
* 生产者和消费者共享的资源Resource对象
* @author xuyi3
* @2016年4月7日 @下午2:01:21
* @Resource
* @功能说明:<br>
* @春风十里不如你
* @备注
*/
public class Resource {

/** 资源名称 */
private String name;
/** 资源标识符 */
private boolean flag = false;
// 区分产品的计数器
private int count = 0;

/**
* 生产产品方法
* @param threadName
*/
public synchronized void produce(String threadName) {
while (isFlag()) {// 如果已经存在数据,生产者就等待消费者消费之后再生产。注意多生产者时这里要使用while循环判断。
// wait()
try {
this.wait();
} catch (InterruptedException e) {
e.printStackTrace();
}

}
setName("产品" + (++count));
System.out.println(threadName + "生产者生产--->" + getName());
setFlag(true);
// 唤醒所有线程
// 这是jdk1.5之前的解决方案,这里正在的意图其实是唤醒消费者所有线程,而不是把生产者和消费者都唤醒。
this.notifyAll();
}

/**
* 消费产品方法
* @param threadName
*/
public synchronized void consumer(String threadName) {

while (!isFlag()) {// 如果没有数据消费者就等待生产者生产之后再消费,多消费者时这里要使用while循环判断。
try {
this.wait();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
System.out.println(threadName + "消费者消费=====》" + getName());
setFlag(false);// 标识已经消费了
// 唤醒所有线程
// 这是jdk1.5之前的解决方案,这里正在的意图其实是唤醒生产者所有线程,而不是把消费者和生产者都唤醒。
this.notifyAll();
}
}

/**
* 生产者线程
* @author xuyi3
* @2016年4月7日 @下午1:38:16
* @ProductThread
* @功能说明:生产产品<br>
* @春风十里不如你
* @备注
*/
public class ProductThread implements Runnable {
// 共享资源对象
private Resource resource;
public ProductThread(Resource resource) {
this.resource = resource;
}
@Override
public void run() {
// 备注:比较优雅的多线程代码,在run()方法体内尽量出现较少的代码,不推荐把同步代码和一些复杂的逻辑放在run()方法体内。
// 因为如果把所有同步代码都放在run()方法体内写的话,非常不好的维护并且代码结构不够清晰。
while (true) {
// 生产者生产产品
resource.produce(Thread.currentThread().getName());
}

}
}

/**
* 消费者对象
* @author xuyi3
* @2016年4月7日 @下午2:07:22
* @ConsumerThread
* @功能说明:<br>
* @春风十里不如你
* @备注
*/
public class ConsumerThread implements Runnable {
// 共享资源Resource对象
private Resource resource;
public ConsumerThread(Resource resource) {
this.resource = resource;
}
@Override
public void run() {
// 备注:比较优雅的多线程代码,在run()方法体内尽量出现较少的代码,不推荐把同步代码和一些复杂的逻辑放在run()方法体内。
// 因为如果把所有同步代码都放在run()方法体内写的话,非常不好的维护并且代码结构不够清晰。
while (true) {
// 消费者消费产品
resource.consumer(Thread.currentThread().getName());
}
}
}

public class AppMain {
public static void main(String[] args) {
// 共享资源对象
Resource resource = new Resource();
// 创建生产者对象
ProductThread productThread = new ProductThread(resource);
// 创建消费者对象
ConsumerThread consumerThread = new ConsumerThread(resource);

// 启动两个线程
new Thread(productThread, "生产者1 ").start();
new Thread(consumerThread, "Consumer1").start();
new Thread(productThread, "生产者2 ").start();
new Thread(consumerThread, "Consumer2").start();
}
}

总结说明