1. class Res
   
2. {
   
3.         private String name;
   
4.         private int count=1;
   
5.         private boolean flag;
   
6. 
   
7.         public synchronized void set(String name)
   
8.         {
   
9.                 while (flag)
   
10.                         try{this.wait();}catch(Exception e){}
    
11.                 this.name=name+"---"+count++;
    
12.                 System.out.println(Thread.currentThread().getName()+"生产者。。。。。。。"+this.name);
    
13.                 flag=true;
    
14.                 this.notifyAll();
    
15.                
    
16.         }
    
17.         public synchronized void out()
    
18.         {
    
19.                 while (!flag)
    
20.                         try{this.wait();}catch(Exception e){}
    
21.                 System.out.println(Thread.currentThread().getName()+"消费者"+this.name);
    
22.                 flag=false;
    
23.                 this.notifyAll();               
    
24.         }
    
25. }
    
26. 
    
27. class Pro implements Runnable
    
28. {
    
29.         private Res r;
    
30. 
    
31.         Pro(Res r)
    
32.         {
    
33.                 this.r=r;
    
34.         }
    
35.         public void run()
    
36.         {
    
37.                 while (true)
    
38.                 {
    
39.                         r.set("商品");
    
40.                 }
    
41.         }
    
42. }
    
43. 
    
44. class Con implements Runnable
    
45. {
    
46.         private Res r;
    
47.         Con(Res r)
    
48.         {
    
49.                 this.r=r;
    
50.         }
    
51.         public void run()
    
52.         {
    
53.                 while (true)
    
54.                 {
    
55.                         r.out();
    
56.                 }
    
57.         }
    
58. }
    
59. 
    
60. 
    
61. class test
    
62. {
    
63.         public static void main(String[] args)
    
64.         {
    
65.                 Res r=new Res();
    
66.                 Pro p=new Pro(r);
    
67.                 Con c=new Con(r);
    
68.                 Thread t1=new Thread(p);
    
69.                 Thread t2=new Thread(p);
    
70.                 Thread t3=new Thread(c);
    
71.                 Thread t4=new Thread(c);
    
72.                 t1.start();
    
73.                 t2.start();
    
74.                 t3.start();
    
75.                 t4.start();
    
76.         }
    
77. 
    
78. }
    
79. 这是什么问题，运行后电脑会嘟嘟几声，然后出现这样的乱码，这代码没什么问题吧

复制代码

同一个Runnable对象建立了2个线程分别执行，而且没有线程安全。。。。。。。。