为什么我试了很多次就是不出来统一数字生产多次或消费多次的情况啊？？是因为cpu是双核的缘故吗？？
视频里说是会出问题的。。。。
朋友们看一下谢谢！

1. public class Produce$CustomerDemo {
   
2. 
   
3.         public static void main(String[] args) {
   
4.                 Resource s = new Resource("烤鸭");
   
5.                 Producer p = new Producer(s);
   
6.                 Consumer c = new Consumer(s);
   
7.         
   
8.                 Thread t1 = new Thread(p);
   
9.                 Thread t3 = new Thread(p);
   
10.                 Thread t2 = new Thread(c);
    
11.                 Thread t4 = new Thread(c);
    
12.                 t1.start();
    
13.                 t3.start();
    
14.                 t2.start();
    
15.                 t4.start();
    
16. 
    
17.         }
    
18. 
    
19. }
    
20. 
    
21. class Resource {
    
22.         String thing;
    
23. 
    
24.         Resource(String thing) {
    
25.                 this.thing = thing;
    
26.         }
    
27. 
    
28.         boolean flag = false;
    
29.         int count = 1;
    
30. 
    
31.         public void set() {
    
32.                 while (true)
    
33.                         synchronized (this) {
    
34.                                 if (!flag) {
    
35.                                         System.out.println(thing + ".....生产" + count);
    
36.                                         flag = true;
    
37.                                 }
    
38.                         }
    
39. 
    
40.         }
    
41. 
    
42.         public void out() {
    
43.                 while (true)
    
44.                         synchronized (this) {
    
45.                                 if (flag) {
    
46.                                         System.out.println(thing + "..............消费" + count++);
    
47.                                         flag = false;
    
48.                                 }
    
49.                         }
    
50.         }
    
51. 
    
52. }
    
53. 
    
54. class Producer implements Runnable {
    
55.         private Resource R;
    
56. 
    
57.         Producer(Resource R) {
    
58.                 this.R = R;
    
59.         }
    
60. 
    
61.         @Override
    
62.         public void run() {
    
63.                 R.set();
    
64. 
    
65.         }
    
66. 
    
67. }
    
68. 
    
69. class Consumer implements Runnable {
    
70.         private Resource R;
    
71. 
    
72.         Consumer(Resource R) {
    
73.                 this.R = R;
    
74.         }
    
75. 
    
76.         @Override
    
77.         public void run() {
    
78.                 R.out();
    
79. 
    
80.         }
    
81. 
    
82. }

复制代码

为什么我试了很多次就是不出来统一数字生产多次或消费多次的情况啊？？是因为cpu是双核的缘故吗？？
视频里说是会出问题的。。。。
朋友们看一下谢谢！

1. public class Produce$CustomerDemo {
   
2. 
   
3.         public static void main(String[] args) {
   
4.                 Resource s = new Resource("烤鸭");
   
5.                 Producer p = new Producer(s);
   
6.                 Consumer c = new Consumer(s);
   
7.         
   
8.                 Thread t1 = new Thread(p);
   
9.                 Thread t3 = new Thread(p);
   
10.                 Thread t2 = new Thread(c);
    
11.                 Thread t4 = new Thread(c);
    
12.                 t1.start();
    
13.                 t3.start();
    
14.                 t2.start();
    
15.                 t4.start();
    
16. 
    
17.         }
    
18. 
    
19. }
    
20. 
    
21. class Resource {
    
22.         String thing;
    
23. 
    
24.         Resource(String thing) {
    
25.                 this.thing = thing;
    
26.         }
    
27. 
    
28.         boolean flag = false;
    
29.         int count = 1;
    
30. 
    
31.         public void set() {
    
32.                 while (true)
    
33.                         synchronized (this) {
    
34.                                 if (!flag) {
    
35.                                         System.out.println(thing + ".....生产" + count);
    
36.                                         flag = true;
    
37.                                 }
    
38.                         }
    
39. 
    
40.         }
    
41. 
    
42.         public void out() {
    
43.                 while (true)
    
44.                         synchronized (this) {
    
45.                                 if (flag) {
    
46.                                         System.out.println(thing + "..............消费" + count++);
    
47.                                         flag = false;
    
48.                                 }
    
49.                         }
    
50.         }
    
51. 
    
52. }
    
53. 
    
54. class Producer implements Runnable {
    
55.         private Resource R;
    
56. 
    
57.         Producer(Resource R) {
    
58.                 this.R = R;
    
59.         }
    
60. 
    
61.         @Override
    
62.         public void run() {
    
63.                 R.set();
    
64. 
    
65.         }
    
66. 
    
67. }
    
68. 
    
69. class Consumer implements Runnable {
    
70.         private Resource R;
    
71. 
    
72.         Consumer(Resource R) {
    
73.                 this.R = R;
    
74.         }
    
75. 
    
76.         @Override
    
77.         public void run() {
    
78.                 R.out();
    
79. 
    
80.         }
    
81. 
    
82. }

复制代码