生产者消费者模式，并发采用ReentrantLock
package org.hkw.multithread;import java.util.concurrent.locks.Lock;import java.util.concurrent.locks.ReentrantLock;public class ThreadDCTest {public static void main(String[] args) {Thread p = new Thread(new Producer("p1"));Thread p2 = new Thread(new Producer("p2"));Thread c = new Thread(new Consumer("c1"));Thread c2 = new Thread(new Consumer("c2"));p.start();p2.start();c.start();c2.start();try {Thread.sleep(1000);} catch (InterruptedException e) {// TODO Auto-generated catch blocke.printStackTrace();}// Storehouse.getInstance().close();c.interrupt();c2.interrupt();p.interrupt();p2.interrupt();}}class Storehouse {static final int STATUS_EMPETY = 0;static final int STATUS_FULL = 1;boolean isClosed = false;String item;int status;Lock lock = new ReentrantLock();private static Storehouse house = new Storehouse();private Storehouse() {}public static Storehouse getInstance() {return house;}public String getItem() {status = STATUS_EMPETY;return item;}public void setItem(String item) {status = STATUS_FULL;this.item = item;}public int getStatus() {return status;}public boolean isEmpty() {return status == STATUS_EMPETY;}public boolean isClosed() {return isClosed;}public void close() {isClosed = true;}public void produce(String name) throws InterruptedException {lock.lockInterruptibly();try {if (isEmpty()) {String item = name + " fill";System.out.println(name + " produce item:" + item);setItem(item);}} finally {lock.unlock();}}public void consum(String name) throws InterruptedException {lock.lockInterruptibly();try {if (!isEmpty()) {System.out.println(name + " consum item:" + house.getItem());}} finally {lock.unlock();}}}class Producer implements Runnable {Storehouse house = Storehouse.getInstance();String name;public Producer(String name) {this.name = name;}@Overridepublic void run() {System.out.println(name + " producer start");while (!Thread.currentThread().isInterrupted() && !house.isClosed()) {try {house.produce(name);} catch (InterruptedException e) {// TODO Auto-generated catch blockSystem.out.println(name + " producer interrupted");Thread.currentThread().interrupt();}}System.out.println(name + " producer end");}}class Consumer implements Runnable {Storehouse house = Storehouse.getInstance();String name;public Consumer(String name) {this.name = name;}@Overridepublic void run() {System.out.println(name + " cosumer start");while (!Thread.currentThread().isInterrupted() && !house.isClosed()) {try {house.consum(name);} catch (InterruptedException e) {// TODO Auto-generated catch blockSystem.out.println(name + " cosumer interrupted");Thread.currentThread().interrupt();}}System.out.println(name + " consumer end");}}