详解Java并发之Condition

package com.ydl.test.juc;

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

public class ConditionUseCase {

  public Lock lock = new ReentrantLock();
  public Condition cOndition= lock.newCondition();

  public static void main(String[] args) {
    ConditionUseCase useCase = new ConditionUseCase();
    ExecutorService executorService = Executors.newFixedThreadPool (2);
    executorService.execute(new Runnable() {
      @Override
      public void run() {
        useCase.conditionWait();
      }
    });
    executorService.execute(new Runnable() {
      @Override
      public void run() {
        useCase.conditionSignal();
      }
    });
  }

  public void conditionWait() {
    lock.lock();
    try {
      System.out.println(Thread.currentThread().getName() + "拿到锁了");
      System.out.println(Thread.currentThread().getName() + "等待信号");
      condition.await();
      System.out.println(Thread.currentThread().getName() + "拿到信号");
    }catch (Exception e){

    }finally {
      lock.unlock();
    }
  }
  public void conditionSignal() {
    lock.lock();
    try {
      Thread.sleep(5000);
      System.out.println(Thread.currentThread().getName() + "拿到锁了");
      condition.signal();
      System.out.println(Thread.currentThread().getName() + "发出信号");
    }catch (Exception e){

    }finally {
      lock.unlock();
    }
  }

}

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

public class BoundedQueue {

  private LinkedList buffer;  //生产者容器
  private int maxSize ;      //容器最大值是多少
  private Lock lock;
  private Condition fullCondition;
  private Condition notFullCondition;
  BoundedQueue(int maxSize){
    this.maxSize = maxSize;
    buffer = new LinkedList();
    lock = new ReentrantLock();
    fullCOndition= lock.newCondition();
    notFullCOndition= lock.newCondition();
  }

  /**
   * 生产者
   * @param obj
   * @throws InterruptedException
   */
  public void put(Object obj) throws InterruptedException {
    lock.lock();  //获取锁
    try {
      while (maxSize == buffer.size()){
        notFullCondition.await();    //满了，添加的线程进入等待状态
      }
      buffer.add(obj);
      fullCondition.signal(); //通知
    } finally {
      lock.unlock();
    }
  }

  /**
   * 消费者
   * @return
   * @throws InterruptedException
   */
  public Object get() throws InterruptedException {
    Object obj;
    lock.lock();
    try {
      while (buffer.size() == 0){ //队列中没有数据了 线程进入等待状态
        fullCondition.await();
      }
      obj = buffer.poll();
      notFullCondition.signal(); //通知
    } finally {
      lock.unlock();
    }
    return obj;
  }

}