一个简单的生产者消费者

使用ReentrantLock以及Condition实现的生产者消费者，也是java 1.5之后推荐写法，不再使用object类的notify()以及wait()方法。直接上代码：

public class Stroge {

    private final int MAX_SIZE = 100;

    private LinkedList<Object> list = new LinkedList<>();

    private Lock lock = new ReentrantLock();
    private Condition notFull = lock.newCondition();
    private Condition notEmpty = lock.newCondition();

    public void produce(int num) {
        lock.lock();
        try {
            while (list.size() + num > MAX_SIZE) {
                System.out.println("当前size：" + list.size() + ",不能再创建" + num + "个产品，await");
                try {
                    notFull.await();
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
            for (int i = 0; i < num; i++) {
                list.add(new Object());
            }
            System.out.println(num + "个产品创建完成，当前size：" + list.size());
            notEmpty.signalAll();
        } finally {
            lock.unlock();
        }
    }

    public void consume(int num) {
        lock.lock();
        try {
            while (list.size() < num) {
                System.out.println("当前size：" + list.size() + ",不能再消费" + num + "个产品，await");
                try {
                    notEmpty.await();
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }

            for (int i = 0; i < num; i++) {
                list.remove(); 
            }
            System.out.println(num + "个产品消费完成，当前size：" + list.size());
            notFull.signalAll();
        } finally {
            lock.unlock();
        }
    }
}
//生产者类
class Producter extends Thread {
    Stroge sto = null;
    private int num;

    public Producter(Stroge sto) {
        this.sto = sto;
    }

    public void setNum(int num) {
        this.num = num;
    }

    public void product(int num) {
        sto.produce(num);
    }

    @Override
    public void run() {
        product(num);
    }
}
//消费者类
class Consumer extends Thread {
    Stroge sto = null;
    private int num;

    public Consumer(Stroge sto) {
        this.sto = sto;
    }

    public void setNum(int num) {
        this.num = num;
    }

    public void consume(int num) {
        sto.consume(num);
    }

    @Override
    public void run() {
        consume(num);
    }
}

测试类：

public class Testprosum {

    public static void main(String[] args) {
        Stroge sto = new Stroge();

        Producter p1 = new Producter(sto);

        Producter p2 = new Producter(sto);
        Producter p3 = new Producter(sto);
        Producter p4 = new Producter(sto);
        Producter p5 = new Producter(sto);

        Consumer c1 = new Consumer(sto);
        Consumer c2 = new Consumer(sto);
        Consumer c3 = new Consumer(sto);
        Consumer c4 = new Consumer(sto);
        Consumer c5 = new Consumer(sto);

        p1.setNum(10);
        p2.setNum(20);
        p3.setNum(30);
        p4.setNum(40);
        p5.setNum(50);

        c1.setNum(10);
        c2.setNum(20);
        c3.setNum(30);
        c4.setNum(40);
        c5.setNum(50);

        p1.start();
        p2.start();
        p3.start();
        p4.start();
        p5.start();
        try {
            Thread.sleep(1000);
        } catch (InterruptedException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        c1.start();
        c2.start();
        c3.start();
        c4.start();
        c5.start();
    }
}

ReentrantLock需要注意try{}finally{lock.unlock();}
OVER