学步园

      生产者与消费者问题是指创建一组“生产者”线程和一组“消费者”线程，让他们进行同步互斥的运行，生产者生产一个产品，消费者就消费掉一个产品，下面我就用java的多线程来实现这个课题。

      本例子的ChuShi代表生产者，XiaoFei代表消费者。

      首先是生产者厨师的代码：

package thread;<br /> public class ChuShi extends Thread{</p> <p> private GongNeng g;<br /> public ChuShi(GongNeng g){<br /> this.g = g;<br /> }</p> <p> public void run(){<br /> for(;;){</p> <p> g.lao();</p> <p> }<br /> }<br /> }

      然后是消费者的代码：

package thread;<br /> public class XiaoFei extends Thread{</p> <p> private GongNeng g;</p> <p> public XiaoFei(GongNeng g){</p> <p> this.g = g;</p> <p> }</p> <p> public void run(){<br /> for(;;){</p> <p> g.chi();</p> <p> }<br /> }<br /> }

      接着是封装了生产者的生产方法和消费者的消费方法的类，该类中的方法要使用synchronized关键字，就可以使run方法同步，也就是说，对于同一个Java类的对象实例，run方法同时只能被一个线程调用，并当前的run执行完后，才能被其他的线程调用。需要注意的是每个线程run()方法调用的synchronized修饰的方法必须是一个实例的方法才能保证同步，所以这个里将生产者和消费者的功能封装在一个实例中，在将他们的实例分别传给生产者和消费者，这样他们就能够同步了，下面是同步的方法代码：

package thread;<br /> public class GongNeng {<br /> private Bing b;</p> <p> public GongNeng(Bing b){<br /> this.b = b;<br /> }</p> <p> public synchronized void lao(){</p> <p> if(b.getBing()<10){</p> <p> try {<br /> Thread.sleep(1500);<br /> } catch (InterruptedException e) {<br /> // TODO Auto-generated catch block<br /> e.printStackTrace();<br /> }</p> <p> System.out.println(Thread.currentThread()+</p> <p> ":厨师烙了一张饼，盘里还剩"+(b.getBing()+1)+"张饼");</p> <p> b.setBing(b.getBing()+1);<br /> }<br /> }</p> <p> public synchronized void chi(){<br /> if(b.getBing()>0){</p> <p> try {<br /> Thread.sleep(2000);<br /> } catch (InterruptedException e) {<br /> // TODO Auto-generated catch block<br /> e.printStackTrace();<br /> }<br /> System.out.println(Thread.currentThread()+</p> <p> ":消费者吃了一张饼，盘里还剩"+(b.getBing()-1)+"张饼");</p> <p> b.setBing(b.getBing()-1);</p> <p> }<br /> }<br /> }

      还有他们对一个消费品进行同步的操作，在这里我们用的是饼：

package thread;<br /> public class Bing {<br /> private int bing = 10;<br /> public int getBing() {<br /> return bing;<br /> }<br /> public void setBing(int bing) {<br /> this.bing = bing;<br /> }</p> <p>}

      下面是主入口方法进行测试：

package thread;<br /> public class Test {<br /> public static void main(String[] args) {</p> <p> //创建饼的实例<br /> Bing b = new Bing();<br /> //创建同步的吃饼和烙饼实例<br /> GongNeng g = new GongNeng(b);<br /> //创建线程两个消费者两个生产者<br /> ChuShi c1 = new ChuShi(g);<br /> ChuShi c2 = new ChuShi(g);<br /> XiaoFei x1 = new XiaoFei(g);<br /> XiaoFei x2 = new XiaoFei(g);</p> <p> //启动线程<br /> c1.start();<br /> c2.start();<br /> x1.start();<br /> x2.start();<br /> }<br /> }

      这个例子就模拟了生产与消费的问题。