黑马程序员技术交流社区

标题: 多线程之间的通信问题 [打印本页]

---

作者: 陌路行者    时间: 2013-7-4 12:24
标题: 多线程之间的通信问题

1. import java.util.concurrent.locks.*;
   
2. class Res
   
3. {
   
4.         private String name;
   
5.         private String sex;
   
6.         private boolean flag = false;
   
7.         Lock lock = new ReentrantLock();
   
8.         Condition condition_in = lock.newCondition();
   
9.         Condition condition_out = lock.newCondition();
   
10.         public void set(String name,String sex) throws InterruptedException
    
11.         {
    
12.                 lock.lock();
    
13.                 if(flag)
    
14.                         try
    
15.                         {
    
16.                                 condition_in.await();
    
17.                                 this.name = name;
    
18.                                 this.sex = sex;
    
19.                                 flag = true;
    
20.                                 condition_out.signal();
    
21.                         }         
    
22.                         finally
    
23.                         {
    
24.                                 lock.unlock();
    
25.                         }
    
26.         }
    
27.         public void out()throws InterruptedException
    
28.         {
    
29.                 lock.lock();
    
30.                 if(!flag)
    
31.                         try
    
32.                         {
    
33.                                 condition_out.await();
    
34.                                 System.out.println(name+".........."+sex);
    
35.                                 flag = false;
    
36.                                 condition_in.signal();
    
37.                         }
    
38.                 finally
    
39.                 {
    
40.                         lock.unlock();
    
41.                 }
    
42. 
    
43.         }
    
44. }
    
45. class Input implements Runnable
    
46. {
    
47.         private Res r;
    
48.         Input(Res r)
    
49.         {
    
50.                 this.r = r;
    
51.         }
    
52.         public void run()
    
53.         {
    
54.                 int x = 0;
    
55.                 while(true)
    
56.                 {
    
57.                         if(x==0)
    
58.                         {
    
59.                                 try
    
60.                                 {
    
61.                                         r.set("mike","man");
    
62.                                 }
    
63.                                 catch (InterruptedException e)
    
64.                                 {
    
65.                                 }               
    
66.                         }
    
67.                         else
    
68.                         {
    
69.                                 try
    
70.                                 {
    
71.                                         r.set("丽丽","女女女");
    
72.                                 }
    
73.                                 catch (InterruptedException e)
    
74.                                 {
    
75.                                 }                        
    
76.                         }
    
77.                         x = (x+1)%2;        
    
78.                 }                                
    
79.         }        
    
80. }
    
81. class Output implements Runnable
    
82. {
    
83.         private Res r;
    
84.         Output(Res r)
    
85.         {
    
86.                 this.r = r;
    
87.         }
    
88.         public void run()
    
89.         {
    
90.                 while(true)
    
91.                 {
    
92.                         try
    
93.                         {
    
94.                                 r.out();
    
95.                         }
    
96.                         catch (InterruptedException e)
    
97.                         {
    
98.                         }               
    
99.                 }
    
100.         }
     
101. }
     
102. class  InputOutputDemo2
     
103. {
     
104.         public static void main(String[] args)
     
105.         {
     
106.                 Res r = new Res();
     
107.                 new Thread(new Input(r)).start();
     
108.                 new Thread(new Input(r)).start();
     
109.                 new Thread(new Output(r)).start();
     
110.                 new Thread(new Output(r)).start();
     
111. 
     
112.         }
     
113. }
     

复制代码

为啥子为是这个样子呢？

---

作者: xuluheng718    时间: 2013-7-4 13:52
看红字：
import java.util.concurrent.locks.*;
class Res
{
        private String name;
        private String sex;
        private boolean flag = false;
        Lock lock = new ReentrantLock();
        Condition condition_in = lock.newCondition();
        Condition condition_out = lock.newCondition();
        public void set(String name,String sex) throws InterruptedException
        {
                lock.lock();
                //if(flag)//线程等待条件有问题应该放在下面
                        try
                        {
                         if(flag)//放在这里
                                condition_in.await();
                                this.name = name;
                                this.sex = sex;
                                flag = true;
                                condition_out.signal();
                        }         
                        finally
                        {
                                lock.unlock();
                        }
        }
        public void out()throws InterruptedException
        {
                lock.lock();
                //if(!flag)//线程等待条件有问题应该放在下面
                        try
                        {
                         if(!flag)//放在这里
                                condition_out.await();
                                System.out.println(name+".........."+sex);
                                flag = false;
                                condition_in.signal();
                        }
                finally
                {
                        lock.unlock();
                }

        }
}
class Input implements Runnable
{
        private Res r;
        Input(Res r)
        {
                this.r = r;
        }
        public void run()
        {
                int x = 0;
                while(true)
                {
                        if(x==0)
                        {
                                try
                                {
                                 
                                        r.set("mike","man");
                                }
                                catch (InterruptedException e)
                                {
                                }               
                        }
                        else
                        {
                                try
                                {
                                        r.set("丽丽","女女女");
                                }
                                catch (InterruptedException e)
                                {
                                }                        
                        }
                        x = (x+1)%2;        
                }                                
        }        
}
class Output implements Runnable
{
        private Res r;
        Output(Res r)
        {
                this.r = r;
        }
        public void run()
        {
                while(true)
                {
                        try
                        {
                                r.out();
                        }
                        catch (InterruptedException e)
                        {
                        }               
                }
        }
}
class  InputOutputDemo2
{
        public static void main(String[] args)
        {
                Res r = new Res();
                new Thread(new Input(r)).start();
                new Thread(new Input(r)).start();
                new Thread(new Output(r)).start();
                new Thread(new Output(r)).start();
        }
}

---

作者: 陌路行者    时间: 2013-7-4 13:58


哦了{:soso_e128:}     谢过!    只怪自己粗心大意

---

作者: 郑先明    时间: 2013-7-4 18:00
每次看到楼主的头像我都很不淡定......

---

作者: 陌路行者    时间: 2013-7-4 18:19

郑先明 发表于 2013-7-4 18:00
每次看到楼主的头像我都很不淡定......

这是为什么呢

---

作者: 郑先明    时间: 2013-7-5 09:51

陌路行者 发表于 2013-7-4 18:19
这是为什么呢

被雷到....

---

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

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