1. package test;
   
2. 
   
3. public class RunnableMassageDemo2 {
   
4. 
   
5.         /**
   
6.          * @param args
   
7.          */
   
8.         public static void main(String[] args) {
   
9.                 Source2 source=new Source2();
   
10.                 InSource2 insource=new InSource2(source);
    
11.                 OutSource2 outsource=new OutSource2(source);
    
12.                 new Thread(insource).start();
    
13.                 new Thread(outsource).start();
    
14.                 new Thread(insource).start();
    
15.                 new Thread(outsource).start();
    
16. 
    
17. 
    
18.         }
    
19. 
    
20. }
    
21. 
    
22. class Source2
    
23. {
    
24.         private String name;
    
25.         private int num=0;
    
26.         private boolean flag=true;
    
27.         public synchronized void Setns()
    
28.         {
    
29.                
    
30.                         while(flag){
    
31.                                 try {
    
32.                                         this.wait();
    
33.                                 } catch (InterruptedException e) {
    
34.                                        
    
35.                                 }
    
36.                         }
    
37.        
    
38.                 name="商品"+num++;
    
39. 
    
40.                 System.out.println("生产  "+name);
    
41.         flag=true;
    
42.         this.notifyAll();
    
43.         }
    
44.          public synchronized void getns()
    
45.          {
    
46.                                 while(!flag){
    
47.                                 try {
    
48.                                         this.wait();
    
49.                                 } catch (InterruptedException e) {
    
50.                                        
    
51.                                         e.printStackTrace();
    
52.                                 }
    
53.                                 }
    
54.                         System.out.println("           消费  "+name);
    
55.                         flag=false;
    
56.                         this.notifyAll();
    
57.                
    
58.          }
    
59. }
    
60. 
    
61.        
    
62.        
    
63.        
    
64. class InSource2 implements Runnable
    
65. {
    
66.         int a=0;
    
67.         Source2 source;
    
68.         InSource2(Source2 source)
    
69.         {
    
70.                 this.source=source;
    
71.         }
    
72.         public void In()
    
73.         {
    
74.                         source.Setns();
    
75.                         }
    
76.        
    
77.         public void run()
    
78.         {
    
79.                 while(true){
    
80.                 In();
    
81.                 }
    
82.         }
    
83.        
    
84.         }
    
85. class OutSource2 implements Runnable
    
86. {
    
87.         Source2 source;
    
88.         OutSource2(Source2 source)
    
89.         {
    
90.                 this.source=source;
    
91.         }
    
92.         public synchronized void Out()
    
93.         {
    
94.                 source.getns();
    
95.         }
    
96.         public void run()
    
97.         {
    
98.                 while(true){
    
99.                 Out();
    
100.                 }
     
101.         }
     
102.         }
     

复制代码

运行结果：
  消费  商品42300
生产  商品42301
           消费  商品42301
生产  商品42302
           消费  商品42302
生产  商品42303
           消费  商品42303
生产  商品42304
           消费  商品42304
生产  商品42305
           消费  商品42305
生产  商品42306
           消费  商品42306
生产  商品42307
           消费  商品42307
生产  商品42308
           消费  商品42308
生产  商品42309
           消费  商品42309
生产  商品42310
           消费  商品42310
生产  商品42311
           消费  商品42311



为什么不是从0开始编号，为什么先运行的是输出？？？？

将flage初始化为false，或true结果都是先运行输出线程，为什么呢？？？

运行速度太快，你加点延长时间看一下

Ezreal 发表于 2014-8-18 09:46
运行速度太快，你加点延长时间看一下

在打印代码之后加了个sleep（10）据正常了，真是谢谢了，我说怎么找了半天都没找到错误呢:)

在打印代码后加        try {
                        Thread.sleep(10);
                } catch (InterruptedException e) {
                        // TODO Auto-generated catch block
                        e.printStackTrace();
                }
就可以了

在打印代码后加        try {
                         Thread.sleep(10);
                 } catch (InterruptedException e) {
                         // TODO Auto-generated catch block
                         e.printStackTrace();
                 }

没想到运行太快也会出问题啊，真是的害我找了半天都没找到

安宁.沉睡 发表于 2014-8-18 10:59
在打印代码之后加了个sleep（10）据正常了，真是谢谢了，我说怎么找了半天都没找到错误呢 ...

本身是没错的，只是CPU运行速度是感觉不出来的。客气:)

学习了，非常好的学习机会

给代码加睡眠试试

让我在这也学到了                        

每个问题都是可以学到的