1. class Res {
   
2.         private String name;
   
3.         private String gender;
   
4.         private boolean flag;
   
5. 
   
6.         public synchronized void set(String name, String gender) {
   
7.                 if (this.flag) {
   
8.                         try {
   
9.                                 this.wait();
   
10.                         } catch (InterruptedException e) {
    
11.                                 e.printStackTrace();
    
12.                         }
    
13.                 } else {
    
14.                         this.name = name;
    
15.                         this.gender = gender;
    
16.                 }
    
17.                 this.flag = true;
    
18.                 this.notify();
    
19.         }
    
20. 
    
21.         public synchronized void out() {
    
22.                 if (!this.flag) {
    
23.                         try {
    
24.                                 this.wait();
    
25.                         } catch (InterruptedException e) {
    
26.                                 e.printStackTrace();
    
27.                         }
    
28.                 } else {
    
29.                         System.out.println(this.name + "," + this.gender);
    
30.                 }
    
31.                 this.flag = false;
    
32.                 this.notify();
    
33.         }
    
34. 
    
35. }
    
36. 
    
37. class Input implements Runnable {
    
38.         private Res r;
    
39. 
    
40.         Input(Res r) {
    
41.                 this.r = r;
    
42.         }
    
43. 
    
44.         public void run() {
    
45.                 int x = 0;
    
46.                 while (true) {
    
47.                         if (x == 0) {
    
48.                                 r.set("zhangsan", "male");
    
49.                         } else {
    
50.                                 r.set("lisi", "female");
    
51.                         }
    
52.                         x = (x + 1) % 2;
    
53.                 }
    
54.         }
    
55. }
    
56. 
    
57. class Output implements Runnable {
    
58.         private Res r;
    
59. 
    
60.         Output(Res r) {
    
61.                 this.r = r;
    
62.         }
    
63. 
    
64.         public void run() {
    
65.                 while (true) {
    
66.                         r.out();
    
67.                 }
    
68.         }
    
69. }
    
70. 
    
71. public class InputOutputDemo {
    
72. 
    
73.         public static void main(String[] args) {
    
74. 
    
75.                 Res r = new Res();
    
76.                 new Thread(new Input(r)).start();
    
77.                 new Thread(new Output(r)).start();
    
78.         }
    
79. 
    
80. }

复制代码

部分结果为:

1. zhangsan,male
   
2. zhangsan,male
   
3. zhangsan,male
   
4. zhangsan,male
   
5. zhangsan,male
   
6. lisi,female
   
7. lisi,female
   
8. lisi,female
   
9. lisi,female
   
10. lisi,female
    
11. zhangsan,male
    
12. zhangsan,male

复制代码

复习之前所学,我看了许久找不到问题所在,为何出书结果是批量输出,而不是有顺序的分别逐个输出.
请各位细心人帮忙分析一下哪里有错误.

{:soso_e136:}原来写的理解错了，看了楼下了解到原来是else方法体的问题- -~~~

你的set函数里不能写else语句，把else删除（里面的代码还是要的，只是不加else）。如果有else的话执行一次if线程等待，被唤醒后直接执行else后的语句而不会执行else里的语句，因为if和else只能执行一个。

楼主的代码格式真的挺看不惯的，所以调整了一下！
class Res
        {
        private String name;
        private String gender;
        private boolean flag = false;
        public synchronized void  set(String name, String gender)
                {
                                if (flag)
                                {
                                        try {
                                                        wait();
                                                }
                                        catch (InterruptedException e)
                                        {
                                                  e.printStackTrace();
                                        }
                                 }
                               //else去掉，下面的一样，这里加上else的话他跟上面的if是一体的，如果线程执行了if，就不会执行else,当线程返回时，判断flag = true,进入等待，唤醒的时候因为已经判断过if了，所以不执行else里面的代码，直接跳过了赋值~~~
                                this.name = name;
                                this.gender = gender;  
                                flag = true;
                                notify();
        }

        public synchronized void out()
                {
                                if (!flag)
                                {
                                        try
                                        {
                                                wait();
                                        }
                                        catch (InterruptedException e)
                                        {
                                                e.printStackTrace();
                                        }         
                                }
                                System.out.println(this.name + "," + this.gender);
                                flag = false;//
         
                                notify();
                        }
}

class Input implements Runnable {

        private Res r;
        Input(Res r)
                {
                        this.r = r;
        }
        public void run()                        
                {
            int x = 0;
            while (true)
                        {
                if (x == 0)
                                {
                      r.set("zhangsan", "male");
                }
                                else
                                {
                                        r.set("lisi", "female");
                }
                x = (x + 1) % 2;
                        }
        }
}


class Output implements Runnable
        {
        private Res r;
        Output(Res r)
                {
                        this.r = r;
        }
        public void run()
                {
            while (true)
                        {
                r.out();               
                        }
        }
}


public class InputOutputDemo {


        public static void main(String[] args) {


                Res r = new Res();

                new Thread(new Input(r)).start();

                new Thread(new Output(r)).start();

        }


}