1. package cn.itcast.demo03_生产和消费者问题;
   
2. 
   
3. public class SetThread extends Thread{
   
4.         private BaoziPu bzp;
   
5.         public SetThread(BaoziPu b){
   
6.                 this.bzp = b;
   
7.         }
   
8.         @Override
   
9.         public void run() {
   
10.                 while(true){
    
11.                         try {
    
12.                                 Thread.sleep(1000);
    
13.                         } catch (InterruptedException e) {
    
14.                                 e.printStackTrace();
    
15.                         }
    
16.                         bzp.setBaozi("包子");
    
17.                 }
    
18.         }
    
19. }
    
20. package cn.itcast.demo03_生产和消费者问题;
    
21. 
    
22. public class GetThread extends Thread{
    
23.         private BaoziPu bzp;
    
24.         public GetThread(BaoziPu bzp){
    
25.                 this.bzp = bzp;
    
26.         }
    
27.        
    
28.         @Override
    
29.         public void run() {
    
30.                 while(true){
    
31.                         String s = this.bzp.getBaozi();
    
32.                         System.out.println(s);
    
33.                 }
    
34.         }
    
35. }
    
36. package cn.itcast.demo03_生产和消费者问题;
    
37. /*
    
38. * 生产和消费者线程：
    
39. *
    
40. * 1.此例只适用于："单生产者" 和 "单消费者" "模式"；(至于多生产和多消费，可以上网搜索相关资料)
    
41. * 2.让当前访问的线程等待：Object-->wait()；
    
42. *   唤醒当前所有等待的线程：Object --> notify()或notifyAll()
    
43. * 3.wait()以及notify()和notifyAll()语句，必须放在"同步代码块"或"同步方法"内，否则抛出异常；
    
44. */
    
45. public class Demo {
    
46.         public static void main(String[] args) {
    
47.                 BaoziPu bzp = new BaoziPu();
    
48.                 SetThread setThread = new SetThread(bzp);
    
49.                 GetThread getThread = new GetThread(bzp);
    
50.                
    
51.                 setThread.start();
    
52.                 getThread.start();
    
53.                
    
54.         }
    
55. }
    
56. package cn.itcast.demo03_生产和消费者问题;
    
57. 
    
58. import java.util.ArrayList;
    
59. import java.util.List;
    
60. 
    
61. public class BaoziPu {
    
62.         private List<String> bzList = new ArrayList<>();
    
63.        
    
64.         public synchronized void setBaozi(String s){
    
65.                 this.bzList.add(s);
    
66.                 System.out.println("唤醒所有等待的消费者......");
    
67.                 notifyAll();//notify()
    
68.                
    
69.         }
    
70.         public synchronized String getBaozi(){
    
71.                 /*if(bzList.size() > 0){
    
72.                         String s = bzList.get(0);
    
73.                         bzList.remove(0);
    
74.                         return s;
    
75.                 }else{
    
76.                         return null;
    
77.                 }*/
    
78.                 if(this.bzList.size() == 0){
    
79.                         //让消费方等待
    
80.                         try {
    
81.                                 System.out.println("没包子了，等会......");
    
82.                                 wait();
    
83.                                 System.out.println("来包子啦......");
    
84.                         } catch (InterruptedException e) {
    
85.                                 e.printStackTrace();
    
86.                         }
    
87.                 }
    
88.                 //取包子
    
89.                 String s = bzList.get(0);
    
90.                 bzList.remove(0);
    
91.                 return s;
    
92.         }
    
93. }
    

复制代码

1. package cn.itcast.demo03_生产和消费者问题;
   
2. 
   
3. public class SetThread extends Thread{
   
4.         private BaoziPu bzp;
   
5.         public SetThread(BaoziPu b){
   
6.                 this.bzp = b;
   
7.         }
   
8.         @Override
   
9.         public void run() {
   
10.                 while(true){
    
11.                         try {
    
12.                                 Thread.sleep(1000);
    
13.                         } catch (InterruptedException e) {
    
14.                                 e.printStackTrace();
    
15.                         }
    
16.                         bzp.setBaozi("包子");
    
17.                 }
    
18.         }
    
19. }
    
20. package cn.itcast.demo03_生产和消费者问题;
    
21. 
    
22. public class GetThread extends Thread{
    
23.         private BaoziPu bzp;
    
24.         public GetThread(BaoziPu bzp){
    
25.                 this.bzp = bzp;
    
26.         }
    
27.        
    
28.         @Override
    
29.         public void run() {
    
30.                 while(true){
    
31.                         String s = this.bzp.getBaozi();
    
32.                         System.out.println(s);
    
33.                 }
    
34.         }
    
35. }
    
36. package cn.itcast.demo03_生产和消费者问题;
    
37. /*
    
38. * 生产和消费者线程：
    
39. *
    
40. * 1.此例只适用于："单生产者" 和 "单消费者" "模式"；(至于多生产和多消费，可以上网搜索相关资料)
    
41. * 2.让当前访问的线程等待：Object-->wait()；
    
42. *   唤醒当前所有等待的线程：Object --> notify()或notifyAll()
    
43. * 3.wait()以及notify()和notifyAll()语句，必须放在"同步代码块"或"同步方法"内，否则抛出异常；
    
44. */
    
45. public class Demo {
    
46.         public static void main(String[] args) {
    
47.                 BaoziPu bzp = new BaoziPu();
    
48.                 SetThread setThread = new SetThread(bzp);
    
49.                 GetThread getThread = new GetThread(bzp);
    
50.                
    
51.                 setThread.start();
    
52.                 getThread.start();
    
53.                
    
54.         }
    
55. }
    
56. package cn.itcast.demo03_生产和消费者问题;
    
57. 
    
58. import java.util.ArrayList;
    
59. import java.util.List;
    
60. 
    
61. public class BaoziPu {
    
62.         private List<String> bzList = new ArrayList<>();
    
63.        
    
64.         public synchronized void setBaozi(String s){
    
65.                 this.bzList.add(s);
    
66.                 System.out.println("唤醒所有等待的消费者......");
    
67.                 notifyAll();//notify()
    
68.                
    
69.         }
    
70.         public synchronized String getBaozi(){
    
71.                 /*if(bzList.size() > 0){
    
72.                         String s = bzList.get(0);
    
73.                         bzList.remove(0);
    
74.                         return s;
    
75.                 }else{
    
76.                         return null;
    
77.                 }*/
    
78.                 if(this.bzList.size() == 0){
    
79.                         //让消费方等待
    
80.                         try {
    
81.                                 System.out.println("没包子了，等会......");
    
82.                                 wait();
    
83.                                 System.out.println("来包子啦......");
    
84.                         } catch (InterruptedException e) {
    
85.                                 e.printStackTrace();
    
86.                         }
    
87.                 }
    
88.                 //取包子
    
89.                 String s = bzList.get(0);
    
90.                 bzList.remove(0);
    
91.                 return s;
    
92.         }
    
93. }
    

复制代码