1. package xuexi1;
   
2. 
   
3. public class InputOutputDemo2 {
   
4. 
   
5.         /**
   
6.          * @param args
   
7.          */
   
8.         public static void main(String[] args) {
   
9.                 // TODO Auto-generated method stub
   
10.                 Resource1 r1=new Resource1();
    
11.                 new Thread(new Input1(r1)).start();
    
12.                 new Thread(new Output1(r1)).start();
    
13.         }
    
14. 
    
15. }
    
16. class Resource1{
    
17.         private String name;
    
18.         private String sex;
    
19.         boolean flag=false;
    
20.         public synchronized void set(String name,String sex){
    
21.                 if(flag){
    
22.                         try{        
    
23.                                 this.wait();
    
24.                            }
    
25.                         catch(Exception e){
    
26.                                 System.out.println(e.toString());
    
27.                            }
    
28.                    }
    
29.                
    
30.            else {
    
31.                 this.name=name;
    
32.                 this.sex=sex;
    
33.                 flag=true;
    
34.                 this.notify();
    
35.            }
    
36.         }
    
37.         public synchronized void get(){
    
38.                 if(!flag){
    
39.                         try{
    
40.                                 this.wait();
    
41.                         }
    
42.                         catch(Exception e){
    
43.                                 e.printStackTrace();
    
44.                         }
    
45.                 }
    
46.                 else{
    
47.                      System.out.println(this.name+"....."+this.sex);
    
48.                      flag=false;
    
49.                      this.notify();
    
50.                 }
    
51.         }
    
52. }
    
53. class Input1 implements Runnable{
    
54.         Resource1 res;
    
55.         
    
56.         Input1(Resource1 res){
    
57.                 this.res=res;
    
58.         }
    
59.         @Override
    
60.         public void run(){
    
61.                 int i=0;
    
62.                 while(true){
    
63.                         if(i==0)
    
64.                                 res.set("123","456");
    
65.                         else if(i==1){
    
66.                                 res.set("ggggg","asdf");
    
67.                         }
    
68.                         i=(i+1)%2;
    
69.                 }
    
70.         }
    
71. }
    
72. class Output1 implements Runnable{
    
73.         Resource1 res;
    
74.         Output1(Resource1 res){
    
75.                 this.res=res;
    
76.         }
    
77.            public void run() {
    
78.                    while(true){
    
79.                            res.get();
    
80.                    }
    
81.             }
    
82.         
    
83. }
    

复制代码

执行结果为
123.....456
123.....456
123.....456
123.....456
123.....456
123.....456
123.....456
但是不是应该为123.....456和ggggg.....asdf交替出现吗？

xuemeng 发表于 2013-5-15 18:42
public class Demo {
public static void main(String[] args) {
  Resource1 r1 = new Resource1();

没有复制啊, 他的代码有问题, 我是用他的代码来给他说明,代码的运行步骤, 然后又给出正确的代码啊!!:L

十分感谢，找好长时间错误了，终于知道了，谢谢

郭军亮 发表于 2013-5-15 20:55
为什么结果不是123.....456和ggggg.....asdf交替出现的呢？

我的回答不是很清楚了吗?

高新星 发表于 2013-5-15 18:36
可能是你执行的时间短吧！
我运行的结果：

为什么结果不是123.....456和ggggg.....asdf交替出现的呢？

public class Demo {
public static void main(String[] args) {
  Resource1 r1 = new Resource1();
  new Thread(new Input1(r1)).start();
  new Thread(new Output1(r1)).start();
}
}
class Resource1 {
private String name;
private String sex;
boolean flag = false;
public synchronized void set(String name, String sex) {
//6, 这是flag的值是true了, 那么线程等待了
  if (flag) {
   try {
//10, Input线程本来是等到这里的, 现在被唤醒了, 本来线程应该继续往下执行的, 如果真往下执行的话, 那么name, sex 的值别是   gggg, asdf, 可是, 因为你这里是一个if...else语句, 那么这就意味着, 你执行if 语句了, else 语句就不会执行,  那么程序又回到第4步, 回到第4 步后 ,执行完第4步后, i的值又变为0了, 那么这时程序执行第2步, 那么这时的值依然是 123, 456, 打印就不会交叉了
    this.wait();
   } catch (Exception e) {
    System.out.println(e.toString());
   }
//3, 程序走到这里来了,执行这里代码, 因为flag为false, 所以执行else语句, name , sex 分别被赋值123, 456, 方法执行完成,程序继续执行, flag = true
  } else {// 这里的else 不能要
   this.name = name;
   this.sex = sex;
   flag = true;
   this.notify();
  }
}
public synchronized void get() {
//9, 线程等待,接下来第10步就是关键地方了, 程序出错就在这里
  if (!flag) {
   try {
    this.wait();
   } catch (Exception e) {
    e.printStackTrace();
   }
  } else {
//8, 打印    name = 123,  sex = 456;
   System.out.println(this.name + "....." + this.sex);
   flag = false;
   this.notify();
  }
}
}
class Input1 implements Runnable {
Resource1 res;
Input1(Resource1 res) {
  this.res = res;
}
//1, 假设程序new Thread(new Input1(r1)).start() 这个线程先开启,
public void run() {
  int i = 0;
  while (true) {
   if (i == 0)
//2, 程序走到这里, 调用  set方法, 执行该方法
    res.set("123", "456");
   else if (i == 1) {
//5, 继续循环执行到这里, 再调用set方法
    res.set("ggggg", "asdf");
   }
//4, 当 res.set("123", "456")方法结束, 执行这里, i == 1, 然后程序,继续while循环,
   i = (i + 1) % 2;
  }
}
}
class Output1 implements Runnable {
Resource1 res;
Output1(Resource1 res) {
  this.res = res;
}
public void run() {
  while (true) {
//7, 线程被唤醒执行.
   res.get();
  }
}
}

下面的代码是正确代码::
public class Demo {
public static void main(String[] args) {
  Resource1 r1 = new Resource1();
  new Thread(new Input1(r1)).start();
  new Thread(new Output1(r1)).start();
}
}
class Input1 implements Runnable {
Resource1 res;
Input1(Resource1 res) {
  this.res = res;
}
public void run() {
  int i = 0;
  while (true) {
   if (i == 0) {
    res.set("123", "456");
   } else if (i == 1) {
    res.set("ggggg", "asdf");
   }
   i = (i + 1) % 2;
  }
}
}
class Output1 implements Runnable {
Resource1 res;
Output1(Resource1 res) {
  this.res = res;
}
public void run() {
  while (true) {
   res.get();
  }
}
}
class Resource1 {
private String name;
private String sex;
boolean flag = false;
public synchronized void set(String name, String sex) {
  if (flag) {
   try {
    this.wait();
   } catch (Exception e) {
    System.out.println(e.toString());
   }
  }
  this.name = name;
  this.sex = sex;
  flag = true;
  this.notify();
}
public synchronized void get() {
  if (!flag) {
   try {
    this.wait();
   } catch (Exception e) {
    e.printStackTrace();
   }
  } else {
   System.out.println(this.name + "....." + this.sex);
   flag = false;
   this.notify();
  }
}
}

可能是你执行的时间短吧！
我运行的结果：

我这个就是两个线程公用一个资源类，让两个线程交替运行的，但结果却不是交替运行的啊？请帮忙看看？

你是创建了两个线程没错，但是：
Resource1 r1=new Resource1(); 你只是创建了一个资源类。

还要创建一个Output1的资源类 ，分出来一个线程来运行启动。

这就是使用实现接口中一个注意的地方。你看一下相关的视频。

这是我的理解，如果有错的地方指点一下，谢谢了！！！