同样是从网上看到的一个需求,需求描述都在代码中。
不多说了,直接贴代码了。相信大家都能够看得懂的!
package cn.yw.bore;import java.util.ArrayList;import java.util.List;import java.util.concurrent.ArrayBlockingQueue;import java.util.concurrent.locks.Condition;import java.util.concurrent.locks.Lock;import java.util.concurrent.locks.ReentrantLock;/** * 使用多线程模拟多线程装弹及射出的过程(实际上这是一个生产者与消费者的问题) * * 要求: * 1.开启3个线程装弹,开启2个线程发射子弹 * 2.弹夹最多只能够装载12颗子弹 * 3.一次只能够发射一枚子弹,发射子弹的时候不能进行装弹,在装弹的时候不能进行发射。 * 4.整个过程就是“装载”、“发射”、“装载”、“发射”、“装载”、“发射” * @author yw-tony * */public class ClipTest { public static void main(String[] args){ final BoreManager manager = new BoreManager(); //开启3个线程装弹 for(int i=0;i<3;i++){ new Thread(new Runnable(){ @Override public void run() { while(true){ manager.loading(); } } }).start(); } //开启两个线程进行发射 for(int i=0;i<2;i++){ new Thread(new Runnable(){ @Override public void run() { while(true){ manager.send(); } } }).start(); } } /** * 模拟装弹以及发射的管理类 * @author yw-tony * */ static class BoreManager{ int boreCount = 1; boolean flag = false;//线程开启标记 //队列中对多存储12个子弹 ArrayBlockingQueueblocking = new ArrayBlockingQueue (12);// List blocking = new ArrayList (); Lock lock = new ReentrantLock(); Condition cond1 = lock.newCondition(); Condition cond2 = lock.newCondition(); /** * 发射 */ public void send(){ 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 void loading(){ 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(); } } }}