java多线程之生产者消费者

package com.mybatis.mybatisplus.thread;/*
 * @author allen
 * @version v1.0
 */

import java.util.concurrent.locks.Condition;
import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;

public class ThreadWait {
    public static void main(String[] args) {
        SumThread sumThread=new SumThread();
          new Thread(()->{
              for (int i = 0; i <10 ; i++) {
                  try {
                      sumThread.add();
                  } catch (InterruptedException e) {
                      e.printStackTrace();
                  }
              }
          }).start();
        new Thread(()->{
            for (int i = 0; i <10 ; i++) {
                try {
                    sumThread.reduce();
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
        }).start();
    }

}

class  SumThread{
     Lock lock=new ReentrantLock();
    Condition condition = lock.newCondition();

    private int count=0;

    public  void add() throws InterruptedException {
         lock.lock();
        try{
            while (count==1){
                condition.await();
            }
            count++;
            condition.signalAll();
            System.out.println(count);
        }
        finally {
            lock.unlock();
        }

    }
    public synchronized void reduce() throws InterruptedException {
        lock.lock();
        try{
            while (count==0){
                condition.await();
            }
            count--;
            condition.signalAll();
            System.out.println(count);
        }
        finally {
            lock.unlock();
        }

    }

}

java多线程之生产者消费者

原文：https://www.cnblogs.com/huangfeialllen/p/14107253.html