1. class Res{
   
2.         private String name;
   
3.         private String sex;
   
4.         private boolean flag = false;
   
5.         
   
6.         public synchronized void set(String name,String sex){
   
7.                 if(flag)
   
8.                         try{this.wait();}catch(Exception e){}
   
9.                 this.name = name;
   
10.                 this.sex = sex;
    
11.                 flag = true;
    
12.                 this.notify();
    
13.         }
    
14.         public synchronized void out(){
    
15.                 if(!flag)
    
16.                         try{this.wait();}catch(Exception e){}
    
17.                 System.out.println(name+"##"+sex);
    
18.                 flag = false;
    
19.                 this.notify();
    
20.         }
    
21. }
    
22. 
    
23. class Input implements Runnable{
    
24.         private Res r;
    
25.         Input(Res r){
    
26.                 this.r = r;
    
27.         }
    
28.         public void run(){
    
29.                 int x = 0;
    
30.                 while(true){
    
31.                         if(x==0)
    
32.                                 r.set("li", "man");
    
33.                         else
    
34.                                 r.set("wang", "woman");
    
35.                         x = (x+1)%2;
    
36.                         
    
37.                 }
    
38.         }
    
39. }
    
40. 
    
41. class Output implements Runnable{
    
42.         private Res r;
    
43.         Output(Res r){
    
44.                 this.r = r;
    
45.         }
    
46.         public void run() {
    
47.                 while(true){
    
48.                         r.out();                        
    
49.                 }
    
50. 
    
51.         }
    
52. }
    
53. class InputOut{
    
54.         public static void main(String[] args){
    
55.                 Res r = new Res();
    
56.                 new Thread(new Input(r)).start();
    
57.                 new Thread(new Output(r)).start();
    
58.         }
    
59. }

复制代码

if(flag) try{this.wait();}catch(Exception e){}  
为什么第8行和第16行需要处理异常？

这个方法是抛出异常的 ,所以你在调用一个抛出异常的方法时 要么try catch  要么调用的函数上继续抛出异常
public final void wait()  throws InterruptedException

这是要抛异常的，这个你如果用IDE工具开发，一般都会有提示你的，要你就到JDK文档上看看，这个方法要不要抛异常，需要抛异常就按它的要求做处理，至于两哪种方式，楼上的已经讲了，我就不再细说了。

public final void wait() throws InterruptedException
这个是wait()方法的概要，因为wait()方法抛出异常，在使用的就需要处理这个异常，对于异常的处理有两种方法：1，继续抛出；2，直接处理（try-catch）
这里使用的是第二种方法。

基本上所有的流都是带有异常的，因为可能出现的错太多了。所有源码上面本身就要求要处理这个异常。

1. public
   
2. interface Runnable {
   
3.     public abstract void run();
   
4. }
   
5. 
   
6. 以上是Runnable的源代码
   
7. 实现Runnable接口的时候，必须要覆盖run()方法。
   
8. 如果不在run()里面用try catch处理异常，则只能写成如下。
   
9. 而如下代码不是Runnable接口中run()方法的重写，编译都没法通过的
   
10. public void run() throws Exception
    
11. {
    
12. 
    
13. };
    

复制代码