为什么我的程序不能交替打印呢？
弄了好久都弄不出来

1. class Person {
   
2.         String name;
   
3.         String sex;
   
4.         boolean flag = false;
   
5. }
   
6. 
   
7. class Input implements Runnable {
   
8.         Person p;
   
9.         int x = 0;
   
10. 
    
11.         public Input(Person p) {
    
12.                 this.p = p;
    
13.         }
    
14. 
    
15.         public void run() {
    
16.                 while (true) {
    
17.                         synchronized (p) {
    
18.                                 while (p.flag)
    
19.                                         try {
    
20.                                                 p.wait();
    
21.                                         } catch (InterruptedException e) {
    
22.                                         }
    
23.                                 if (x == 0) {
    
24.                                         p.name = "张三";
    
25.                                         p.sex = "男";
    
26.                                 } else {
    
27.                                         p.name = "lili";
    
28.                                         p.sex = "nv";
    
29.                                 }
    
30.                                 p.flag = true;
    
31.                                 p.notifyAll();
    
32.                                 x = (x + 1) % 2;
    
33.                         }
    
34.                 }
    
35.         }
    
36. }
    
37. 
    
38. class Output implements Runnable {
    
39.         Person p;
    
40. 
    
41.         public Output(Person p) {
    
42.                 this.p = p;
    
43.         }
    
44. 
    
45.         public void run() {
    
46.                 while (true) {
    
47.                         synchronized (p) {
    
48.                                 while (!p.flag)
    
49.                                         try {
    
50.                                                 p.wait();
    
51.                                         } catch (InterruptedException e) {
    
52.                                         }
    
53.                                 System.out.println(p.name + "...." + p.sex);
    
54.                                 p.flag = false;
    
55.                                 p.notifyAll();
    
56.                         }
    
57.                 }
    
58.         }
    
59. }
    
60. 
    
61. public class Demo {
    
62.         public static void main(String[] args) {
    
63.                 Person p = new Person();
    
64. 
    
65.                 new Thread(new Input(p)).start();
    
66.                 new Thread(new Input(p)).start();
    
67.                 new Thread(new Output(p)).start();
    
68.                 new Thread(new Output(p)).start();
    
69. 
    
70.         }
    
71. }

复制代码

目前  只发现while(flag)后面没｛｝
下面那个也是一样的

白月留梦 发表于 2015-6-24 00:17
目前  只发现while(flag)后面没｛｝
下面那个也是一样的

加了括号也没用

p.notifyAll();是唤醒所有线程，包含对方所等待的线程，你不使用同步代码块，使用Lock锁试试看看行不行

你确定是你的线程出问题吗？你带上线程名称仔细看看。
线程安全没有问题，这里出现重复输出的现象，是一种巧合

1. if (x == 0) {
   
2.                                         p.name = "张三";
   
3.                                         p.sex = "男";
   
4.                                 } else {
   
5.                                         p.name = "lili";
   
6.                                         p.sex = "nv";
   
7.                                 }
   
8.                                 p.flag = true;
   
9.                                 p.notifyAll();
   
10.                                 x = (x + 1) % 2;

复制代码

如果在线程2中，x==0,此时输出“张三，男”，当执行完p.notifyAll()；还未执行后面的奇偶变换时候，此时线程2切换到线程3，此时x还是0，此时就会输出线程3的“张三，男”，这样就会出现重复的现象，但是他们属于不同的线程，所以没有线程安全问题。

你要是想看出效果，可以在输出后面加一个可变的量作为区别

1. public void run() {
   
2.             int temp = 0;
   
3.             while (true) {
   
4.                     synchronized (p) {
   
5.                             while (!p.flag)
   
6.                                     try {
   
7.                                             p.wait();
   
8.                                     } catch (InterruptedException e) {
   
9.                                     }
   
10.                             System.out.println(p.name + "...." + p.sex
    
11.                                             +"------->" + (temp++));
    
12.                             p.flag = false;
    
13.                             p.notifyAll();
    
14.                     }
    
15.             }

复制代码

这样就看的很清楚了。

楼主 你的程序本来就实现了交替输入和打印这个事情，但是，你的x变量是线程的私有变量，线程判断x是否为0或1就是在线程自己的范围内判断的，你仔细想想就知道为啥重复打印两次了 我帮你改了下程序，这里会输出你想要的结果

1. class Person {
   
2.         String name;
   
3.         String sex;
   
4.         boolean flag = false;
   
5.                 int x = 0;
   
6. }
   
7. 
   
8. class Input implements Runnable {
   
9.         Person p;
   
10.         
    
11. 
    
12.         public Input(Person p) {
    
13.                 this.p = p;
    
14.         }
    
15. 
    
16.         public void run() {
    
17.                 while (true) {
    
18.                         synchronized (p) {
    
19.                                 while (p.flag)
    
20.                                         try {
    
21.                                                 p.wait();
    
22.                                         } catch (InterruptedException e) {
    
23.                                         }
    
24.                                 if (p.x == 0) {
    
25.                                         p.name = "张三";
    
26.                                         p.sex = "男";
    
27.                                 } else {
    
28.                                         p.name = "lili";
    
29.                                         p.sex = "nv";
    
30.                                 }
    
31.                                                                 p.x = (p.x + 1) % 2;
    
32.                                 p.flag = true;
    
33.                                 p.notifyAll();
    
34. 
    
35.                         }
    
36.                 }
    
37.         }
    
38. }
    

复制代码

我是隔壁老王呀 发表于 2015-6-24 08:46
你确定是你的线程出问题吗？你带上线程名称仔细看看。
线程安全没有问题，这里出现重复输出的现象，是一种 ...

这不是巧合，无论你测试多少遍，都会是这个结果，原因是楼主把判断交替输出的变量当成了线程的私有变量

都是大神！学习啦。。。

guiqulaixi 发表于 2015-6-24 10:10
这不是巧合，无论你测试多少遍，都会是这个结果，原因是楼主把判断交替输出的变量当成了线程的私有变量 ...

嗯，学习了。