packagecn.yw.bore;importjava.util.ArrayList;importjava.util.List;importjava.util.concurrent.ArrayBlockingQueue;importjava.util.concurrent.locks.Condition;importjava.util.concurrent.locks.Lock;importjava.util.concurrent.locks.ReentrantLock;/*** 使用多线程模拟多线程装弹及射出的过程(实际上这是一个生产者与消费者的问题)

*

* 要求：

* 1.开启3个线程装弹，开启2个线程发射子弹

* 2.弹夹最多只能够装载12颗子弹

* 3.一次只能够发射一枚子弹，发射子弹的时候不能进行装弹，在装弹的时候不能进行发射。

* 4.整个过程就是“装载”、“发射”、“装载”、“发射”、“装载”、“发射”

*@authoryw-tony

**/

public classClipTest {public static voidmain(String[] args){final BoreManager manager = newBoreManager();//开启3个线程装弹

for(int i=0;i<3;i++){new Thread(newRunnable(){

@Overridepublic voidrun() {while(true){

manager.loading();

}

}

}).start();

}//开启两个线程进行发射

for(int i=0;i<2;i++){new Thread(newRunnable(){

@Overridepublic voidrun() {while(true){

manager.send();

}

}

}).start();

}

}/*** 模拟装弹以及发射的管理类

*@authoryw-tony

**/

static classBoreManager{int boreCount = 1;boolean flag = false;//线程开启标记//队列中对多存储12个子弹

ArrayBlockingQueue blocking = new ArrayBlockingQueue(12);//List blocking = new ArrayList();

Lock lock = newReentrantLock();

Condition cond1=lock.newCondition();

Condition cond2=lock.newCondition();/*** 发射*/

public voidsend(){

lock.lock();try{if(!flag){

cond1.await();

}if(blocking.size() == 0){

flag= false;

cond2.signal();

}else{

Integer i=blocking.take();

System.out.println("发射第："+i+"个子弹！");

blocking.remove(i);//将该元素从队列中移除

Thread.sleep(100);//模拟子弹发射的慢过程

}

}catch(Exception e){

e.printStackTrace();

}finally{

lock.unlock();

}

}/*** 装载*/

public voidloading(){

lock.lock();try{if(flag){

cond2.await();

}if(blocking.size()==12){

flag= true;

cond1.signal();

}else{

blocking.put(boreCount);

System.out.println("第："+boreCount+"个子弹装载完成！");

Thread.sleep(100);//模拟装弹慢过程

boreCount++;

}

}catch(Exception e){

e.printStackTrace();

}finally{

lock.unlock();

}

}

}

}