下面是代码--->

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

复制代码

下面是运行结果--->

1. Exception in thread "Thread-0" zhangsan...男
   
2. java.lang.IllegalMonitorStateException
   
3.         at java.lang.Object.notify(Native Method)
   
4.         at yting.day11.thread.Input.run(ThreadCommunication.java:49)
   
5.         at java.lang.Thread.run(Thread.java:662)
   
6. Exception in thread "Thread-1" java.lang.IllegalMonitorStateException
   
7.         at java.lang.Object.notify(Native Method)
   
8.         at yting.day11.thread.Output.run(ThreadCommunication.java:78)
   
9.         at java.lang.Thread.run(Thread.java:662)
   

复制代码

一直抱这个异常，怎么回事啊？坐等大神指导、、、谢了先！

synchronized (r)
既然你同步的是这个对象，你就应该调用这个对象的wait() notify()方法 去告知线程等待和唤醒

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

复制代码

你试试

肖亚光 发表于 2013-9-27 15:33
synchronized (r)
既然你同步的是这个对象，你就应该调用这个对象的wait() notify()方法 去告知线程等待和 ...

谢谢了，后来饿才发现弄错了呢！