生产者消费者模型(单个生产者和单个消费者)

生产者消费者模型(单个生产者和单个消费者)

场景描述

代码展示

/**
* 生产者和消费者共享的资源Resource对象
* @author xuyi3
* @2016年4月7日 @下午2:01:21
* @Resource
* @功能说明:<br>
* @春风十里不如你
* @备注
*/
public class Resource {
/** 资源名称 */
private String name;
/** 资源标识符 */
private boolean flag = false;
//省略setter 和 getter 方法
}

/**
* 生产者线程
* @author xuyi3
* @2016年4月7日 @下午1:38:16
* @ProductThread
* @功能说明:生产产品<br>
* @春风十里不如你
* @备注
*/
public class ProductThread implements Runnable {
//共享资源Resource对象
private Resource resource;
public ProductThread(Resource resource) {
this.resource = resource;
}
@Override
public void run() {
int count = 1;
// 生产产品
while (true) {

synchronized (resource) {//共享资源对象(同步的锁要相同否则就错误)
if (resource.isFlag()) {// 标识已经有资源
// wait();
try {
resource.wait();
} catch (InterruptedException e) {
e.printStackTrace();
}
} else {
// 生产资源
resource.setName("产品" + count);
System.out.println("生产者生产--->" + resource.getName());
count++;
resource.setFlag(true);
// notify();
resource.notify();
}
}
}
}
}

/**
* 消费者对象
* @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() {

while (true) {
synchronized (resource) {//共享资源对象(同步的锁要相同否则就错误)
if (!resource.isFlag()) {// 标识没有数据
// wait()
try {
resource.wait();
} catch (InterruptedException e) {
e.printStackTrace();
}
} else {
System.out.println("消费者消费===》" + resource.getName());
resource.setFlag(false);// 标识已经消费了
// notify()
resource.notify();
}
}
}
}
}

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).start();
new Thread(consumerThread).start();
}
}

总结说明