Java多线程-生产者消费者例子-使用Synchronized实现
import java.util.LinkedList;
import java.util.List;
/**
* Created by wisgood .
*/
public class ProducerConsumerWithSynchronizedDemo {
public static void main(String[] args) {
ProductFactoryWithSynchronized productFactory = new ProductFactoryWithSynchronized(10);
new Thread(new ProducerWithSynchronized(productFactory),"1号生产者").start();
new Thread(new ConsumerWithSynchronized(productFactory),"1号消费者").start();
new Thread(new ConsumerWithSynchronized(productFactory),"2号消费者").start();
}
}
class ProductFactoryWithSynchronized {
private List<String> products;
private int capacity = 0;
public ProductFactoryWithSynchronized(int capacity) {
this.capacity = capacity;
products = new LinkedList<>();
}
// 生产产品
public synchronized void produce(String product) {
while (capacity == products.size()) {
try {
//打日志的目的是更好的观察消费者和生产者状态
System.out.println("警告：线程("+Thread.currentThread().getName() + ")准备生产产品，但产品池已满");
wait();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
products.add(product);
System.out.println("线程("+Thread.currentThread().getName() + ")生产了一件产品:" + product+";当前剩余商品"+products.size()+"个");
notify();
}
// 消费产品
public synchronized String consume() {
while (products.size()==0) {
try {
//打日志的目的是更好的观察消费者和生产者状态
System.out.println("警告：线程("+Thread.currentThread().getName() + ")准备消费产品，但当前没有产品");
wait();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
String product = products.remove(0) ;
System.out.println("线程("+Thread.currentThread().getName() + ")消费了一件产品:" + product+";当前剩余商品"+products.size()+"个");
notify();
return product;
}
}
// 生产者
class ProducerWithSynchronized implements Runnable {
private ProductFactoryWithSynchronized productFactory;
public ProducerWithSynchronized(ProductFactoryWithSynchronized productFactory) {
this.productFactory = productFactory;
}
public void run() {
int i = 0 ;
while (true) {
productFactory.produce(String.valueOf(i));
i++;
try {
Thread.sleep(10);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
}
// 消费者
class ConsumerWithSynchronized implements Runnable {
private ProductFactoryWithSynchronized productFactory;
public ConsumerWithSynchronized(ProductFactoryWithSynchronized productFactory) {
this.productFactory = productFactory;
}
public void run() {
while (true) {
productFactory.consume();
try {
Thread.sleep(200);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
}
输出结果
线程(1号生产者)生产了一件产品:0;当前剩余商品1个
线程(1号消费者)消费了一件产品:0;当前剩余商品0个
警告：线程(2号消费者)准备消费产品，但当前没有产品
线程(1号生产者)生产了一件产品:1;当前剩余商品1个
线程(2号消费者)消费了一件产品:1;当前剩余商品0个
线程(1号生产者)生产了一件产品:2;当前剩余商品1个
线程(1号生产者)生产了一件产品:3;当前剩余商品2个
线程(1号生产者)生产了一件产品:4;当前剩余商品3个
线程(1号生产者)生产了一件产品:5;当前剩余商品4个
线程(1号生产者)生产了一件产品:6;当前剩余商品5个
线程(1号生产者)生产了一件产品:7;当前剩余商品6个
线程(1号生产者)生产了一件产品:8;当前剩余商品7个
线程(1号生产者)生产了一件产品:9;当前剩余商品8个
线程(1号生产者)生产了一件产品:10;当前剩余商品9个
线程(1号生产者)生产了一件产品:11;当前剩余商品10个
警告：线程(1号生产者)准备生产产品，但产品池已满
线程(1号消费者)消费了一件产品:2;当前剩余商品9个
线程(1号生产者)生产了一件产品:12;当前剩余商品10个
线程(2号消费者)消费了一件产品:3;当前剩余商品9个
线程(1号生产者)生产了一件产品:13;当前剩余商品10个
警告：线程(1号生产者)准备生产产品，但产品池已满
线程(1号消费者)消费了一件产品:4;当前剩余商品9个
线程(1号生产者)生产了一件产品:14;当前剩余商品10个
警告：线程(1号生产者)准备生产产品，但产品池已满
线程(2号消费者)消费了一件产品:5;当前剩余商品9个
线程(1号生产者)生产了一件产品:15;当前剩余商品10个
警告：线程(1号生产者)准备生产产品，但产品池已满
线程(1号消费者)消费了一件产品:6;当前剩余商品9个
线程(1号生产者)生产了一件产品:16;当前剩余商品10个
警告：线程(1号生产者)准备生产产品，但产品池已满
线程(2号消费者)消费了一件产品:7;当前剩余商品9个
线程(1号生产者)生产了一件产品:17;当前剩余商品10个
警告：线程(1号生产者)准备生产产品，但产品池已满
线程(1号消费者)消费了一件产品:8;当前剩余商品9个
线程(1号生产者)生产了一件产品:18;当前剩余商品10个
警告：线程(1号生产者)准备生产产品，但产品池已满
线程(2号消费者)消费了一件产品:9;当前剩余商品9个
原文地址http://www.bieryun.com/2512.html
