1. <p>----Resource类：
   
2. package com.Demo;</p><p>public class Resource {
   
3. private String name;
   
4. private String sex;
   
5. private boolean flog=false;
   
6. public void set(String name,String sex){
   
7.   synchronized (this) {
   
8.    if(flog){
   
9.     try{
   
10.      this.wait();
    
11.      }catch (Exception e) {
    
12.      }
    
13.    }
    
14.    this.name=name;
    
15.    this.sex=sex;
    
16.    flog=true;
    
17.    this.notify();
    
18.   }
    
19. }
    
20. 
    
21. public void get(){
    
22.   synchronized (this) {
    
23.    if(!flog){
    
24.     try{
    
25.      this.wait();
    
26.     }catch (Exception e) {
    
27.     }
    
28.    }
    
29.    System.out.println(name+"......"+sex);
    
30.    flog=false;
    
31.    this.notify();
    
32.   }
    
33. }
    
34. }
    
35. 
    
36. -----Input类：
    
37. package com.Demo;</p><p>public class Input implements Runnable{
    
38. private Resource r;
    
39. public Input(Resource r){
    
40.   this.r=r;
    
41. }
    
42. public void run() {
    
43.   int x=0;
    
44.   while(true){
    
45.    if(x==0){
    
46.     r.set("丽丽", "女");
    
47.    }else{
    
48.     r.set("龙龙", "男");
    
49.    }
    
50.    x=(x+1)%2;
    
51.   }
    
52. }
    
53. }
    
54. ----Output类:
    
55. package com.Demo;</p><p>public class Output implements Runnable{
    
56. private Resource r;
    
57. public Output(Resource r){
    
58.   this.r=r;
    
59. }
    
60. public void run() {
    
61.   while(true){
    
62.    r.get();
    
63.   }
    
64. }</p><p>}
    
65. 
    
66. ---MainDemo类:
    
67. package com.Demo;</p><p>public class MainDemo {
    
68. public static void main(String[] args) {
    
69.   new Thread(new Input(new Resource())).start();
    
70.   new Thread(new Output(new Resource())).start();
    
71. }
    
72. }
    
73. 
    
74. 打印结果是null....null闪一下然后不输出，求指导。。</p>

复制代码

1. class Resouce
   
2. {
   
3.         private String name;
   
4.         private String sex;
   
5.         private boolean flag = true;
   
6.         Resouce()
   
7.         {
   
8.         }
   
9.         Resouce(String name,String sex)
   
10.         {
    
11.                 this.name = name;
    
12.                 this.sex = sex;
    
13.         }
    
14.        
    
15.         public synchronized void setRes(String name,String sex)
    
16.         {
    
17.                 if(!flag)
    
18.                         try
    
19.                         {
    
20.                                 wait();
    
21.                         }
    
22.                         catch (InterruptedException ie)
    
23.                         {
    
24.                                 ie.printStackTrace();
    
25.                         }
    
26.                 this.name = name;
    
27.                 this.sex = sex;
    
28. 
    
29.                 flag = false;
    
30.                 notify();
    
31.         }
    
32.        
    
33.         public synchronized void getRes()
    
34.         {
    
35.                 if(flag)
    
36.                         try
    
37.                         {
    
38.                                 wait();
    
39.                         }
    
40.                         catch (InterruptedException ie)
    
41.                         {
    
42.                                 ie.printStackTrace();
    
43.                         }
    
44.                 System.out.println(/*Thread.currentThread().getName()+*/"name:"+name+"..."+"sex:"+sex);
    
45.                 flag = true;
    
46.                 notify();
    
47.         }
    
48. }
    
49. 
    
50. class  Input implements Runnable
    
51. {
    
52.         private  Resouce r;
    
53. 
    
54.         Input(Resouce r)
    
55.         {
    
56.                 this.r = r;
    
57.         }
    
58.         public void run()
    
59.         {
    
60.                 int x = 0;
    
61.                 while(true)
    
62.                 {
    
63.                         if(x==0)
    
64.                                 r.setRes("丽丽","女");
    
65.                         else
    
66.                                 r.setRes("龙龙","男");
    
67.                         x = (x+1)%2;
    
68.                 }
    
69.         }
    
70. }
    
71. class Output implements Runnable
    
72. {
    
73.         private Resouce r;
    
74.         Output(Resouce r)
    
75.         {
    
76.                 this.r = r;
    
77.         }
    
78.         public void run()
    
79.         {
    
80.                 while(true)
    
81.                 {
    
82.                         r.getRes();
    
83.                 }
    
84.         }
    
85. }
    
86. 
    
87. class  InputOutputThread2
    
88. {
    
89.         public static void main(String[] args)
    
90.         {
    
91.                 Resouce r = new Resouce();
    
92.                
    
93.                 new Thread(new Input(r),"存储").start();
    
94.                 new Thread(new Output(r),"读出").start();
    
95.         }
    
96. }

复制代码

看看这个结果行不行

你定义了两个Resource类的对象，可以这样分析一下，
先分别给两个Resource类的对象命名一下，一个是Resource A ,一个是Resource B;
简称一下线程,一个是线程input,一个是线程output
input线程先启动,给A 设置进去了name和age的值,然后就wait等着output线程来取,
可是,output线程已启动却是等着取出B的值,
它们将一直等下去,因为不会有线程给B设置,也不会有线程去取A的值
所以,把main方法里的代码修改如下:
Resource res = new Resource();  //创建一个Resource对象让两个线程去操作,否则你定义的synchronized同步方法没有意义嘛!
new Thread(new Input(res)).start();
new Thread(new Output(res)).start();
另外,唤醒线程的方法,尽量不要用notify;要用notifyAll,因为线程都是线程调度器来调用的,你是控制不了的,所以用notify有时会出问题

袁艳超 发表于 2012-9-5 16:37
你定义了两个Resource类的对象，可以这样分析一下，
先分别给两个Resource类的对象命名一下，一个是Resourc ...

额   创建对象那里写错了。。找了半天就是没找main方法中的代码。。受教了。。:hug: