黑马程序员技术交流社区

标题: java多线程实现生产者消费者问题？ [打印本页]

---

作者: zly1992008    时间: 2014-6-11 18:16
标题: java多线程实现生产者消费者问题？


大家都知道java多线程，以及多线程的线程间通信，那么同志们来一起复习下这个问题吧？{:3_64:}

---

作者: liujie445012100    时间: 2014-6-11 22:31
单生产和单消费只需要判断一次就行用if
多生产多消费需要判断多次，要while，就这么简单

---

作者: 少先队员    时间: 2014-6-12 01:33
获取锁  释放锁    循环判断锁

---

作者: 18353666072    时间: 2014-6-12 08:28

1. class Resource
   
2. {
   
3.         private String name;
   
4.         private int  count = 1;
   
5.         private boolean flag = false;
   
6.        
   
7.         public synchronized void set(String name)
   
8.         {        while(flag)
   
9.                         try {this.wait();} catch(Exception e){}
   
10.                 this.name = name+"....."+count++;
    
11.                 System.out.println(Thread.currentThread().getName()+"---生产者--"+this.name);
    
12.                 flag=true;
    
13.                 this.notifyAll();
    
14.         }
    
15.        
    
16.         public synchronized void out()
    
17.         {        while(!flag)
    
18.                         try {this.wait();} catch(Exception e){}
    
19.                 System.out.println(Thread.currentThread().getName()+"---消费者--"+this.name);
    
20.                 flag=false;
    
21.                 this.notifyAll();
    
22.         }
    
23. }
    
24. class Producer implements Runnable
    
25. {
    
26.         private Resource res;
    
27.         Producer(Resource res)
    
28.         {
    
29.                 this.res = res ;
    
30.         }
    
31.         public void run()
    
32.         {
    
33.                 while(true)
    
34.                 {
    
35.                         res.set("+商品+");
    
36.                 }
    
37.         }
    
38. }
    
39. class Consumer implements Runnable
    
40. {
    
41.         private Resource res;
    
42.         Consumer(Resource res)
    
43.         {
    
44.                 this.res = res;
    
45.         }
    
46.         public void run()
    
47.         {
    
48.                 while(true)
    
49.                 {
    
50.                         res.out();
    
51.                 }
    
52.         }
    
53. }
    
54. 
    
55. class InputOutputDemo04
    
56. {
    
57.         public  static void main(String[] args)
    
58.         {
    
59.                 Resource r = new Resource();
    
60.                
    
61.                 Producer p = new Producer(r);
    
62.                 Consumer c = new Consumer(r);
    
63.                
    
64.                 Thread t1 = new Thread(p);
    
65.                 Thread t2 = new Thread(p);
    
66.                 Thread t3 = new Thread(c);
    
67.                 Thread t4 = new Thread(c);
    
68.                 t1.start();
    
69.                 t2.start();
    
70.                 t3.start();
    
71.                 t4.start();
    
72.                
    
73.                 // new Thread(new Consumer(r)).start();
    
74.                  //new Thread(new Producer(r)).start();
    
75.                 //System.out.println("hello word");
    
76.         }
    
77. }

复制代码

代码一交，一目了然。。。哇卡卡卡卡卡{:3_51:}

---

作者: zly1992008    时间: 2014-6-12 10:20

18353666072 发表于 2014-6-12 08:28
代码一交，一目了然。。。哇卡卡卡卡卡

1.5升级版你懂得的。。。。。爽就一个字

---

作者: 18353666072    时间: 2014-6-12 11:56

zly1992008 发表于 2014-6-12 10:20
1.5升级版你懂得的。。。。。爽就一个字

lock..............................

---

欢迎光临 黑马程序员技术交流社区 (http://bbs.itheima.com/)

黑马程序员IT技术论坛 X3.2