举例说明，最好是毕老师的代码:)

1. public class InputOutputDemo2
   
2. {
   
3.         public static void main(String[] args)
   
4.         {
   
5.                 Res1 r=new Res1();
   
6.                 Thread t1=new Thread(new Input1(r));//1.创建了一个Input线程；
   
7.                 Thread t2=new Thread(new Output1(r));
   
8. //2.创建了一个Output线程；
   
9.                 t1.start();
   
10.                 t2.start();
    
11.                
    
12.         }
    
13. }
    
14. class Res1
    
15. {
    
16.         private String name;
    
17.         private String sex;
    
18.         private boolean flag=false;//初始标记为false；
    
19.         public synchronized void set(String name,String sex)
    
20.         {
    
21.                 if(flag)
    
22.                         try{this.wait();}catch(InterruptedException e){}
    
23.                 this.name=name;
    
24.                 this.sex=sex;
    
25.                 flag=true;
    
26.                 this.notify();
    
27.         }
    
28.         public synchronized void out()
    
29.         {
    
30.                 if(!flag)
    
31.                         try{this.wait();}catch(InterruptedException e){}
    
32.                 System.out.println(name+"-----"+sex);
    
33.                 flag=false;
    
34.                 this.notify();
    
35.         }
    
36. }
    
37. class Input1 implements Runnable
    
38. {
    
39.         private Res1 r;
    
40.         Input1(Res1 r)
    
41.         {
    
42.                 this.r=r;
    
43.         }
    
44.         public void run()//3.假设t1先执行。
    
45.         {
    
46.                 int x=0;
    
47.                 while(true)
    
48.                 {
    
49.                         if(x==0)
    
50.                                 r.set("zhangsan","man");//4.到此调用set方法，flag为假，赋值。将flag置为true。
    
51.                         else
    
52.                                 r.set("lisi","woman");//6.因为循环执行这个set方法，flag为真，当前线程wait()，并放弃this锁。t2开始执行。
    
53.                         x=(x+1)%2;//5.x由0变为1.
    
54.                 }
    
55.         }
    
56. }
    
57. class Output1 implements Runnable
    
58. {
    
59.         private Res1 r;
    
60.         Output1(Res1 r)
    
61.         {
    
62.                 this.r=r;
    
63.         }
    
64.         public void run()
    
65.         {
    
66.                 while(true)
    
67.                 {
    
68.                         r.out();//(！flag)为flase，输出，flag置为假。循环，(!flag)为真，wait()。notify()将t1唤醒。
    
69.                 }
    
70.         }
    
71. }
    
72. 
    

复制代码

这是只有两个线程的情况，当出现多线程时，便会出现错误。
在线程间通讯时使用Lock更为方便，更有针对性。

1. package day12;
   
2. 
   
3. import java.util.concurrent.locks.Condition;
   
4. import java.util.concurrent.locks.Lock;
   
5. import java.util.concurrent.locks.ReentrantLock;
   
6. 
   
7. public class ProducerCustomerDemo2
   
8. {
   
9.                 public static void main(String[] args)
   
10.                 {
    
11.                         Resource1 r=new Resource1();
    
12.                         Producer1 p=new Producer1(r);
    
13.                         Customer1 c=new Customer1(r);
    
14.                         Thread t1=new Thread(p);
    
15.                         Thread t2=new Thread(p);
    
16.                         Thread t3=new Thread(c);
    
17.                         Thread t4=new Thread(c);
    
18.                         t1.start();
    
19.                         t2.start();
    
20.                         t3.start();
    
21.                         t4.start();
    
22.                 }
    
23. }
    
24. class Resource1
    
25. {
    
26.         private String name;
    
27.         private int count;
    
28.         private boolean flag=false;
    
29.         private Lock lock=new ReentrantLock();//1.5版本新特性。相当与synchronized语句。
    
30.         //private Condition condition=lock.newCondition();//Condition相当与监视器方法，由lock的newCondition()方法获取。
    
31.         private Condition condition_pro=lock.newCondition();//每个lock可以建立多个condition，它们可以互相等待唤醒。
    
32.         private Condition condition_cus=lock.newCondition();
    
33.         public void set(String name)throws InterruptedException
    
34.         {
    
35.                 lock.lock();//上锁
    
36.                 try
    
37.                 {
    
38.                         while(flag)
    
39.                                 condition_pro.await();//由await()替换wait()方法
    
40.                         this.name=name+"----"+count++;
    
41.                         System.out.println(Thread.currentThread().getName()+"...生产者。。。"+this.name);
    
42.                         flag=true;
    
43.                         condition_cus.signal();//由signal()替换notify(),由signalAll()替换notifyAll()。只唤醒消费方法；
    
44.                 }
    
45.                 finally
    
46.                 {
    
47.                         lock.unlock();
    
48.                 }
    
49.         }
    
50.         public void out()throws InterruptedException
    
51.         {
    
52.                 lock.lock();
    
53.                 try
    
54.                 {
    
55.                         while(!flag)
    
56.                                 condition_cus.await();
    
57.                         System.out.println(Thread.currentThread().getName()+"...消费者。。。。。。。。"+this.name);
    
58.                         flag=false;
    
59.                         condition_pro.signal();//只唤醒生产方法。
    
60.                 }
    
61.                 finally
    
62.                 {
    
63.                         lock.unlock();
    
64.                 }
    
65.         }
    
66. }
    
67. class Producer1 implements Runnable
    
68. {
    
69.         private Resource1 r;
    
70.         Producer1(Resource1 r)
    
71.         {
    
72.                 this.r=r;
    
73.         }
    
74.         public void run()
    
75.         {
    
76.                 while(true)
    
77.                 {
    
78.                         try
    
79.                         {
    
80.                                 r.set("商品");
    
81.                         }
    
82.                         catch(InterruptedException e){}
    
83.                 }
    
84.         }
    
85. }
    
86. class Customer1 implements Runnable
    
87. {
    
88.         private Resource1 r;
    
89.         Customer1(Resource1 r)
    
90.         {
    
91.                 this.r=r;
    
92.         }
    
93.         public void run()
    
94.         {
    
95.                 while(true)
    
96.                 {
    
97.                         try
    
98.                         {
    
99.                                 r.out();
    
100.                         }
     
101.                         catch(InterruptedException e){}
     
102.                 }
     
103.         }
     
104. }

复制代码

我一般回答没人回答的简单问题..有人回答的我一般不看..可这样都抢不到分

黑马连家华 发表于 2012-8-18 17:28
我一般回答没人回答的简单问题..有人回答的我一般不看..可这样都抢不到分

张同学 此言差矣 技术分就像钱一样 越多越开心 别人会羡慕我的