生产者消费者

1、ackage ProducerConsumer;unport java.util.LnikedList;unport java.util.concuiTent.Semaphore;public class Producerconsumer 1 public static void niain(Striiig args) (Queue queue = new Queue。；newTluead(newProduceiXqueue/生产者 lH).start();new Tluead(new ProduceiXqueue/生产者 2”).start();new Tluead(new Producei

2、Xqueue/生产者 3”).start();newTluead(newConsumer(queue/消费者 lH).stanQ;new Tluead(new Consumer(queue/消 费者 2H).staitQ;new Tluead(new Consumer(queue/消 费者 3H).staitQ;class Signs (static Semaphore empty = new Seniaphore(lO);static Semaphore fiill = new Semaphore(O);static Semaphore mutex = new Seniaphore(l);c

3、lass Producer miplements Runnable private Queue queue;private String name;public Producer(Queue queue, Stiiiig name) ( superQ;tliis.queue = queue; = name;public void run() trywliile (true) (/System.out.println(name);Signs.empty.acquueQ;Signs.mutex.acquueQ;System, out. pnntln(”生产一个产品放入仓库) q

4、ueue.put(new PioductQ);Signs, mutex, release。;Signs.full.release();/Thiead.cunentThiead().sleep(100);) catch (IntenuptedException e) ( e.priiitStackTiace();)class Consumer miplements Rmmable (private Queue queue;String name;public Consumer(Queue queue, String name) (superQ;tills.queue = queue;tills.

5、name = name;public void run() trywliile (true) (/System.out.println(name);Signs.full.acquiie();Signs, mutex, acquire。；System, out. printing从仓库拿出一个产品消费”);queue.get();Signs, mutex, release。;Signs. empty.releaseQ;/Thiead.cunentThiead().sleep(100);) catch (IntenuptedException e) ( e.priiitStackTiace();)/队列class Queue (private LinkedList 11 = new LuikedListQ;syiichioiiized void put(Object o) (ll.addLast(o); /尾部添加元素syncluoiiized public Object get() (return H.iemoveFiistQ; / 从前面删除 public boolean empty() (