看完毕老师的多线程视频，自己写的第三个源码。
运行效果截图：

1. /*
   
2. 需求分析：有一群生产者和一群消费者,
   
3. 生产的商品都由一个对象来保存，生产者生产时，消费者不得进行购买动作，生产完成后才可以进行购买
   
4. 同样消费者购买商品时生产者不得生产。
   
5. */
   
6. 
   
7. class ProducerConsumer
   
8. {
   
9.     public static void main(String[] args)
   
10.     {
    
11.         Resource r=new Resource();
    
12.         Producer p=new Producer(r);
    
13.         Consumer c=new Consumer(r);
    
14.         new Thread(p,"生产者1").start();
    
15.         new Thread(p,"生产者2").start();
    
16.         new Thread(p,"生产者3").start();
    
17.         new Thread(c,"消费者1").start();
    
18.         new Thread(c,"消费者2").start();
    
19.         new Thread(c,"消费者3").start();
    
20.         new Thread(c,"消费者4").start();
    
21.         new Thread(c,"消费者5").start();
    
22.     }
    
23. }
    
24. class Resource
    
25. {
    
26.     String name;
    
27.     int count;
    
28.     boolean flag=false;
    
29.     public synchronized void produce(String name){
    
30.         while(flag)
    
31.             try{wait();}catch(Exception e){}
    
32.         this.name=name;
    
33.         System.out.println(Thread.currentThread().getName()+":生产一个商品,信息如下：");
    
34.         System.out.println("产品名称："+name+"，产品编号："+(++count));
    
35.         System.out.println("-----------------------------------------------------");
    
36.         flag=true;
    
37.         notifyAll();
    
38.     }
    
39.     public synchronized void consume(){
    
40.          while(!flag)
    
41.             try{wait();}catch(Exception e){}
    
42.         System.out.println(Thread.currentThread().getName()+":某个商品被购买,信息如下：");
    
43.         System.out.println("产品名称："+name+"，产品编号为："+count);
    
44.         System.out.println("-----------------------------------------------------");
    
45.         flag=false;
    
46.         notifyAll();
    
47.     }
    
48. }
    
49. class Producer implements Runnable
    
50. {
    
51.     private final Resource r;
    
52.     Producer(Resource r){
    
53.         this.r=r;
    
54.     }
    
55.     public void run(){
    
56.         while(true)
    
57.             r.produce(creatRandomName());
    
58.     }
    
59.     public static String creatRandomName(){
    
60.         String[] name={"加饭酒","茅台酒","21金维他","两面针","牙膏","电视机","计算机","桌子","衣服"};
    
61.         return name[(int)(Math.random()*name.length)];
    
62.     }
    
63. }
    
64. class Consumer implements Runnable
    
65. {
    
66.     private final Resource r;
    
67.     Consumer(Resource r){
    
68.         this.r=r;
    
69.     }
    
70.     public void run(){
    
71.         while(true)
    
72.             r.consume();
    
73.     }
    
74. }

复制代码

abc784990536 发表于 2014-12-26 11:00
不是跟毕老师一样的吗！！

看第四楼，或者看
http://bbs.itheima.com/forum.php ... p;page=1#pid1144994

不是跟毕老师一样的吗！！

as604049322 发表于 2014-12-25 16:44
我是菜鸟。。想上55期，，，现在这个速度估计指望不上了

我也是哎。。。

再占一楼，，，便于以后再次升级。。。

找寻小龙猫 发表于 2014-12-25 16:16
大神第几期的？

我是菜鸟。。想上55期，，，现在这个速度估计指望不上了

占楼，用于升级资源。之前一个资源只能放一个商品，现在升级到可以放100个商品。。。请等待楼主升级……
已经成功升级，代码如下：

1. import java.util.concurrent.locks.*;
   
2. 
   
3. class ProducerConsumer2
   
4. {
   
5.     public static void main(String[] args)
   
6.     {
   
7.         Resource r=new Resource();
   
8.         Producer p=new Producer(r);
   
9.         Consumer c=new Consumer(r);
   
10.         new Thread(p,"生产者1").start();
    
11.         new Thread(p,"生产者2").start();
    
12.         new Thread(p,"生产者3").start();
    
13.         new Thread(c,"消费者1").start();
    
14.         new Thread(c,"消费者2").start();
    
15.         new Thread(c,"消费者3").start();
    
16.         new Thread(c,"消费者4").start();
    
17.         new Thread(c,"消费者5").start();
    
18.     }
    
19. }
    
20. class commodity
    
21. {
    
22.     String name;//产品名称
    
23.     int number;//产品编号
    
24.     commodity(int num){
    
25.         this.name=creatRandomName();
    
26.         this.number=num;
    
27.     }
    
28.     public static String creatRandomName(){
    
29.         String[] name={"加饭酒","茅台酒","21金维他","两面针","牙膏","电视机","计算机","桌子","衣服"};
    
30.         return name[(int)(Math.random()*name.length)];
    
31.     }
    
32. }
    
33. class Resource
    
34. {
    
35.     final commodity[] storehouse = new commodity[100];//仓库中的保存的货物
    
36.     int total;//仓库中当前的货物总数
    
37.     int proPointer;//生产者当前指针
    
38.     int conPointer;//消费者当前指针
    
39.    
    
40.     int count;//产品编号
    
41.     private Lock lock=new ReentrantLock();
    
42.     private Condition pro=lock.newCondition();
    
43.     private Condition con=lock.newCondition();
    
44.     public void produce() throws InterruptedException {
    
45.         lock.lock();
    
46.         try{
    
47.             while(total==storehouse.length)
    
48.                 pro.await();
    
49.             storehouse[proPointer]=new commodity(count++);
    
50.             proPointer=(proPointer+1)%storehouse.length;
    
51.             ++total;
    
52.             con.signal();
    
53.         }finally{
    
54.             lock.unlock();
    
55.         }
    
56.     }
    
57.     public void consume() throws InterruptedException {
    
58.         lock.lock();
    
59.         try{
    
60.             while(total==0)
    
61.                 con.await();
    
62.             commodity temp=storehouse[conPointer];
    
63.             conPointer=(conPointer+1)%storehouse.length;
    
64.             --total;
    
65.             System.out.println(Thread.currentThread().getName()+":某个商品被购买,信息如下：");
    
66.             System.out.println("产品名称："+temp.name+"，产品编号为："+temp.number);
    
67.             System.out.println("-----------------------------------------------------");
    
68.             pro.signal();
    
69.         }finally{
    
70.              lock.unlock();
    
71.         }
    
72.     }
    
73. }
    
74. class Producer implements Runnable
    
75. {
    
76.     private final Resource r;
    
77.     Producer(Resource r){
    
78.         this.r=r;
    
79.     }
    
80.     public void run(){
    
81.         while(true){
    
82.             try{
    
83.                 r.produce();
    
84.             }catch (InterruptedException e){
    
85.                 e.toString();
    
86.             }
    
87.         }
    
88.     }
    
89.    
    
90. }
    
91. class Consumer implements Runnable
    
92. {
    
93.     private final Resource r;
    
94.     Consumer(Resource r){
    
95.         this.r=r;
    
96.     }
    
97.     public void run(){
    
98.         while(true){
    
99.             try{
    
100.                 r.consume();
     
101.             }catch (InterruptedException e){
     
102.                 e.toString();
     
103.             }
     
104.         }
     
105.     }
     
106. }

复制代码

大神第几期的？

。。。。。。。。。。

JDK1.5 的升级版

1. 
   
2. import java.util.concurrent.locks.*;
   
3. 
   
4. class ProducerConsumer2
   
5. {
   
6.     public static void main(String[] args)
   
7.     {
   
8.         Resource r=new Resource();
   
9.         Producer p=new Producer(r);
   
10.         Consumer c=new Consumer(r);
    
11.         new Thread(p,"生产者1").start();
    
12.         new Thread(p,"生产者2").start();
    
13.         new Thread(p,"生产者3").start();
    
14.         new Thread(c,"消费者1").start();
    
15.         new Thread(c,"消费者2").start();
    
16.         new Thread(c,"消费者3").start();
    
17.         new Thread(c,"消费者4").start();
    
18.         new Thread(c,"消费者5").start();
    
19.     }
    
20. }
    
21. class Resource
    
22. {
    
23.     String name;
    
24.     int count;
    
25.     boolean flag=false;
    
26.     private Lock lock=new ReentrantLock();
    
27.     private Condition pro=lock.newCondition();
    
28.     private Condition con=lock.newCondition();
    
29.     public void produce(String name) throws InterruptedException {
    
30.         lock.lock();
    
31.         try{
    
32.             while(flag)
    
33.                 pro.await();
    
34.             this.name=name;
    
35.             System.out.println(Thread.currentThread().getName()+":生产一个商品,信息如下：");
    
36.             System.out.println("产品名称："+name+"，产品编号："+(++count));
    
37.             System.out.println("-----------------------------------------------------");
    
38.             flag=true;
    
39.             con.signal();
    
40.         }finally{
    
41.             lock.unlock();
    
42.         }
    
43.     }
    
44.     public void consume() throws InterruptedException {
    
45.         lock.lock();
    
46.         try{
    
47.             while(!flag)
    
48.                 con.await();
    
49.             System.out.println(Thread.currentThread().getName()+":某个商品被购买,信息如下：");
    
50.             System.out.println("产品名称："+name+"，产品编号为："+count);
    
51.             System.out.println("-----------------------------------------------------");
    
52.             flag=false;
    
53.             pro.signal();
    
54.         }finally{
    
55.              lock.unlock();
    
56.         }
    
57.     }
    
58. }
    
59. class Producer implements Runnable
    
60. {
    
61.     private final Resource r;
    
62.     Producer(Resource r){
    
63.         this.r=r;
    
64.     }
    
65.     public void run(){
    
66.         while(true){
    
67.             try{
    
68.                 r.produce(creatRandomName());
    
69.             }catch (InterruptedException e){
    
70.                 e.toString();
    
71.             }
    
72.         }
    
73.     }
    
74.     public static String creatRandomName(){
    
75.         String[] name={"加饭酒","茅台酒","21金维他","两面针","牙膏","电视机","计算机","桌子","衣服"};
    
76.         return name[(int)(Math.random()*name.length)];
    
77.     }
    
78. }
    
79. class Consumer implements Runnable
    
80. {
    
81.     private final Resource r;
    
82.     Consumer(Resource r){
    
83.         this.r=r;
    
84.     }
    
85.     public void run(){
    
86.         while(true){
    
87.             try{
    
88.                 r.consume();
    
89.             }catch (InterruptedException e){
    
90.                 e.toString();
    
91.             }
    
92.         }
    
93.     }
    
94. }

复制代码