利用Lock和Condition实现 

package com.sy.blockingQueue;

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

class ShareResource{
	private int number=0;
	private Lock lock = new ReentrantLock();
	Condition condition = lock.newCondition();
	
	public void inCrement() throws InterruptedException{
		try {
			lock.lock();
			while(number != 0){
				condition.await();
			}
			number ++;
			System.out.println(Thread.currentThread().getName()+"\t"+number);
			condition.signalAll();
		} catch (Exception e) {
			e.printStackTrace();
		}finally{
			lock.unlock();
		}
	}
	
	public void deCrement() throws InterruptedException{
		try {
			lock.lock();
			while(number != 1){
				condition.await();
			}
			number --;
			System.out.println(Thread.currentThread().getName()+"\t"+number);
			condition.signalAll();
		} catch (Exception e) {
			e.printStackTrace();
		}finally{
			lock.unlock();
		}
	}
}

public class TraditionalProducerConsumer {
	public static void main(String[] args) {
		ShareResource resource = new ShareResource();
		
		for(int i=0;i<5;i++){
			new Thread(()->{
				try {
					resource.inCrement();
				} catch (Exception e) {
					e.printStackTrace();
				}
			},"A").start();
		}
		
		for(int i=0;i<5;i++){
			new Thread(()->{
				try {
					resource.deCrement();
				} catch (Exception e) {
					e.printStackTrace();
				}
			},"B").start();
		}
	}
}

 

---