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