对于多线程的同步我掌握的还不扎实，谁能提供一些代码例子给我看看，如果有注解就更好了，非常感谢！

1. /*
   
2. 需求：解决通信问题。对资源同步。
   
3. */
   
4. import java.util.concurrent.locks.*;
   
5. class ThreadTest
   
6. {
   
7.         public static void main(String[] args)
   
8.         {
   
9.                 Res r = new Res();
   
10.                 Output op = new Output(r);
    
11.                 Input ip = new Input(r);
    
12.                 Thread t1 = new Thread(op);
    
13.                 Thread t3 = new Thread(ip);
    
14.                 Thread t2 = new Thread(op);
    
15.                 Thread t4 = new Thread(ip);
    
16. 
    
17.                 t1.start();
    
18.                 t2.start();
    
19.                 t3.start();
    
20.                 t4.start();
    
21.         }
    
22. }
    
23. class Res
    
24. {
    
25.         private String name;
    
26.         private int age;
    
27.         boolean flag;
    
28.         Lock lock = new ReentrantLock();//拿锁。
    
29.         Condition notEmpty = lock.newCondition();//建立condition对象。因为一把锁可以有多个对象。
    
30.         Condition notFull = lock.newCondition();
    
31.         //这个锁是this锁。
    
32.         /*public synchronized void set(String name,int age)
    
33.         {
    
34.                 while(flag)
    
35.                         try
    
36.                         {
    
37.                                 this.wait();//满足条件线程等待。
    
38.                         }
    
39.                         catch (Exception e)
    
40.                         {
    
41.                                 System.out.println(e.toString());
    
42.                         }
    
43.                 this.name = name;
    
44.                 this.age = age;
    
45.                 flag = true;//改标记。
    
46.                 notifyAll();//唤醒所有线程。
    
47.         }
    
48.         public synchronized void get()
    
49.         {
    
50.                 while(!flag)
    
51.                         try
    
52.                         {
    
53.                                 this.wait();//满足条件线程等待。
    
54.                         }
    
55.                         catch (Exception e)
    
56.                         {
    
57.                                 System.out.println(e.toString());
    
58.                         }
    
59.                 System.out.println(this.name  + "" + this.age);
    
60.                 flag = false;//改标记
    
61.                 notifyAll();//唤醒所有线程。
    
62.         }*/
    
63.         public void set(String name, int age)
    
64.         {
    
65.                 lock.lock();//先锁门。
    
66.                 try
    
67.                 {                       
    
68.                         while(flag)
    
69.                                 notEmpty.await();//满足条件线程等待。
    
70.                         this.name = name;
    
71.                         this.age = age;
    
72.                         flag = true;//改标记。
    
73.                         notFull.signal();//唤醒对方线程。
    
74. 
    
75.                 }
    
76.                 catch (Exception e)
    
77.                 {
    
78.                         System.out.println(e.toString());
    
79.                 }
    
80.                 finally
    
81.                 {
    
82.                         lock.unlock();//开门。
    
83.                 }
    
84.         }
    
85.         public void get()
    
86.         {
    
87.                 lock.lock();
    
88.                 try
    
89.                 {
    
90.                         while(!flag)
    
91.                                 notFull.await();//满足条件线程等待。
    
92.                         System.out.println(Thread.currentThread() + this.name + ":::" + this.age);
    
93.                         flag = false;//改标记。
    
94.                         notEmpty.signal();//唤醒对方线程
    
95.                 }
    
96.                 catch (Exception e)
    
97.                 {
    
98.                         System.out.println(e.toString());
    
99.                 }
    
100.                 finally
     
101.                 {
     
102.                         lock.unlock();
     
103.                 }
     
104.         }       
     
105. }
     
106. class Input implements Runnable
     
107. {
     
108.         private Res r;
     
109.         Input(Res r)
     
110.         {
     
111.                 this.r = r;
     
112.         }
     
113.         public void run()
     
114.         {
     
115.                 int x = 1;
     
116.                 while(true)
     
117.                 {
     
118.                         if(x == 1)
     
119.                                 r.set("mike",34);
     
120.                         else
     
121.                                 r.set("李丽",25);
     
122.                         x = x % 2;
     
123.                         x++;               
     
124.                 }
     
125.         }
     
126. }
     
127. class Output implements Runnable
     
128. {
     
129.         private Res r;
     
130.         Output(Res r)
     
131.         {
     
132.                 this.r = r;
     
133.         }
     
134.         public void run()
     
135.         {
     
136.                 while (true)
     
137.                 {
     
138.                         r.get();
     
139.                 }
     
140.         }
     
141. }

复制代码

skill20 发表于 2014-5-8 17:55

嗯，谢谢！   这个demo不错！

刚好也学到这块，学习一下

其实拿毕老师的代码和视频多看几遍敲几遍 效果更好哦。

伍叶竹 发表于 2014-5-8 19:08
其实拿毕老师的代码和视频多看几遍敲几遍 效果更好哦。

也是额，贵在坚持！