多线程略难,时间也少. 第十二天,两天了还没吃透.

不过我想,多线程应该是java中的重点,学好这里下面才会相对轻松些...

很期待13天的String ~

1. 
   
2. /*
   
3. 生产者消费者练习
   
4. synchronized版
   
5. 
   
6. */
   
7. 
   
8. public class ProducerConsumerDemo {
   
9. 
   
10.         public static void main(String[] args) {
    
11.        
    
12.                 Resource res = new Resource();
    
13.                
    
14.                 new Thread(new Producer(res)).start();
    
15.                 new Thread(new Producer(res)).start();
    
16.                 new Thread(new Consumer(res)).start();
    
17.                 new Thread(new Consumer(res)).start();
    
18.         }
    
19. }
    
20. 
    
21. class Resource {
    
22.        
    
23.         private String name;
    
24.         private int count = 1;
    
25.         private boolean flag;
    
26. 
    
27.         public synchronized void set(String name) {
    
28.        
    
29.                 while(flag)
    
30.                         try{wait();} catch(Exception e) {}
    
31.                 this.name = name + "--" + count++;
    
32.                 System.out.println(Thread.currentThread().getName() + "\t生产者" + this.name);
    
33.                 flag = true;
    
34.                 notifyAll();
    
35.         }
    
36.        
    
37.         public synchronized void out() {
    
38.        
    
39.                 while(!flag)
    
40.                         try{wait();} catch(Exception e) {}
    
41.                 System.out.println(Thread.currentThread().getName() + "\t\t消费者" + this.name);
    
42.                 flag = false;
    
43.                 notifyAll();
    
44.         }
    
45. }
    
46. 
    
47. 
    
48. class Producer implements Runnable {
    
49. 
    
50.         Resource res;
    
51.        
    
52.         public Producer(Resource res) {
    
53.        
    
54.                 this.res = res;
    
55.         }
    
56.        
    
57.         public void run() {
    
58.        
    
59.                 while(true) {
    
60.                
    
61.                         res.set("商品");
    
62.                 }
    
63.         }
    
64. }
    
65. 
    
66. class Consumer implements Runnable {
    
67. 
    
68.         Resource res;
    
69.        
    
70.         public Consumer(Resource res) {
    
71.        
    
72.                 this.res = res;
    
73.         }
    
74.        
    
75.         public void run() {
    
76.        
    
77.                 while(true) {
    
78.                
    
79.                         try{Thread.sleep(500);} catch(Exception e) {}
    
80.                         res.out();
    
81.                 }
    
82.         }
    
83. }
    

复制代码

1. import java.util.concurrent.locks.*;
   
2. 
   
3. 
   
4. /*
   
5. 生产者消费者练习
   
6. ReentrantLock版
   
7. 
   
8. */
   
9. public class ProducerConsumerDemo2 {
   
10. 
    
11.         public static void main(String[] args) {
    
12.        
    
13.                 Resource res = new Resource();
    
14.                
    
15.                 new Thread(new Producer(res)).start();
    
16.                 new Thread(new Producer(res)).start();
    
17.                 new Thread(new Consumer(res)).start();
    
18.                 new Thread(new Consumer(res)).start();
    
19.         }
    
20. }
    
21. 
    
22. class Resource {
    
23. 
    
24.         private String name;
    
25.         private int count = 1;
    
26.         private boolean flag;
    
27.        
    
28.         private Lock lock = new ReentrantLock();
    
29.         private Condition condition_pro = lock.newCondition();
    
30.         private Condition condition_con = lock.newCondition();
    
31.        
    
32.         public void set(String name)
    
33.                 throws InterruptedException {
    
34.        
    
35.                 lock.lock();
    
36.                 try {
    
37.                
    
38.                         if(flag)
    
39.                                 condition_pro.await();
    
40.                         this.name = name + "--" + count++;
    
41.                         System.out.println(Thread.currentThread().getName() + "生产者" + this.name);
    
42.                         flag = true;
    
43.                         condition_con.signal();
    
44.                 }
    
45.                 finally {
    
46.                
    
47.                         lock.unlock();
    
48.                 }
    
49.         }
    
50.        
    
51.         public void out()
    
52.                 throws InterruptedException {
    
53.        
    
54.                 lock.lock();
    
55.                 try {
    
56.                
    
57.                         if(!flag)
    
58.                                 condition_con.await();
    
59.                         System.out.println(Thread.currentThread().getName() + "\t\t消费者" + this.name);
    
60.                         flag = false;
    
61.                         condition_pro.signal();
    
62.                 }
    
63.                 finally {
    
64.                
    
65.                         lock.unlock();
    
66.                 }
    
67.         }
    
68. }
    
69. 
    
70. 
    
71. 
    
72. class Producer implements Runnable {
    
73. 
    
74.         Resource res;
    
75.        
    
76.         public Producer(Resource res) {
    
77.        
    
78.                 this.res = res;
    
79.         }
    
80.        
    
81.         public void run() {
    
82.        
    
83.                 while(true) {
    
84.                
    
85.                         try {
    
86.                                
    
87.                                 res.set("商品");
    
88.                         }
    
89.                         catch(InterruptedException e) {
    
90.                        
    
91.                         }
    
92.                 }
    
93.         }
    
94. }
    
95. 
    
96. class Consumer implements Runnable {
    
97. 
    
98.         Resource res;
    
99.        
    
100.         public Consumer(Resource res) {
     
101.        
     
102.                 this.res = res;
     
103.         }
     
104.        
     
105.         public void run() {
     
106.        
     
107.                 while(true) {
     
108.                
     
109.                         try {
     
110.                        
     
111.                                 res.out();
     
112.                         }
     
113.                         catch(InterruptedException e) {
     
114.                        
     
115.                         }
     
116.                 }
     
117.         }
     
118. }

复制代码

如果能把张老师的Java并发库视频看完，并用里面的每种工具把生产者消费者问题实现一遍，你的Java多线程就算入门了

感谢分享。

fantacyleo 发表于 2014-9-14 01:12
如果能把张老师的Java并发库视频看完，并用里面的每种工具把生产者消费者问题实现一遍，你的Java多线程就算 ...

好的,一定实践~!  

并发库的视频在哪里啊

学习一下

学习学习