java多线程的等待唤醒机制及如何解决同步过程中的安全问题

/* 
class Person{
   String name;
   String sex;
   boolean flag = true;
   public void setPerson(String name, String sex){  
				 this.sex=sex;
				 this.name=name;   
   }
}
class Input implements Runnable{
   int x=0;
   Person p;
   Input(Person p){
      this.p=p;
   }
   public void run(){
       while(true){
		   if(x==1){
			  p.setPerson("hjz", "man");
		   }
		   else p.setPerson("哈哈哈", "女女女女");
		   x=(x+1)%2;
	   }
   } 
}

class Output implements Runnable{
   int x=0;
   Person p;
   Output(Person p){
      this.p=p;
   }
   public void run(){
       while(true){
	       System.out.println(p.name + "....." + p.sex);
	   }
   } 
} 
public class Test{
    public static void main(String[] args){
	     Person p = new Person();
		 new Thread(new Input(p)).start();
		 new Thread(new Output(p)).start();
	}
}
*/

/*
输出的结果：
哈哈哈.....man
hjz.....man
hjz.....man
哈哈哈.....man
hjz.....女女女女
*/

//线程安全隐患出现：首先考虑到是多线程操作了同一资源，所以要用同步！
/* 
class Person{
   String name;
   String sex;
   boolean flag = true;
   public void setPerson(String name, String sex){  
				 this.sex=sex;
				 this.name=name;   
   }
}

class Input implements Runnable{
   int x=0;
   Person p;
   Input(Person p){
      this.p=p;
   }
   public void run(){
       while(true){
	      synchronized(new Object()){
			   if(x==1){
				  p.setPerson("hjz", "man");
			   }
			   else p.setPerson("哈哈哈", "女女女女");
			   x=(x+1)%2;
		  }
	   }
   } 
}

class Output implements Runnable{
   int x=0;
   Person p;
   Output(Person p){
      this.p=p;
   }
   public void run(){
       while(true){
	       System.out.println(p.name + "....." + p.sex);
	   }
   } 
}
public class Test{
    public static void main(String[] args){
	     Person p = new Person();
		 new Thread(new Input(p)).start();
		 new Thread(new Output(p)).start();
	}
}
 */

//同步完成之后，发现还是出现安全隐患的情况，在考虑一下是否访问统一资源的多个线程用的是同一个锁！
//本例中的应将输入输出一起同步（注意输入输出不在同一个线程之中,输出线程不会获得 Person p对象的控制权！）
/*   class Input implements Runnable{
   int x=0;
   Person p;
   
   Input(Person p){
      this.p=p;
   }
   public void run(){
       while(true){
	      synchronized(p){
		       if(p.flag){
			     try{
					 p.wait();
				   }catch(InterruptedException e){
				   }
			   }
		       if(!p.flag){
				   if(x==1){
					  p.setPerson("hjz", "man");
				   }
				   else p.setPerson("哈哈哈", "女女女女");
				   x=(x+1)%2;
			   }
			   
			   p.flag=true;
			   p.notify();
			   
		  }
	   }
   } 
} */


//现在的代码是将同步放到函数里！真正开发过的时候就是这样实现，也就是我们多个线程同事操作一个类对象
//调用该类提供的对外方法，并将调用的方法进行同步！防止安全隐患！
class Person{
   String name;
   String sex;
   boolean flag = true;
   public void setPerson(String name, String sex){
       synchronized(this){
	     if(!flag){
		     try{
			    wait();
			 }catch(InterruptedException e){}
		 }
	     if(flag){
				 this.sex=sex;
				 try{
					Thread.sleep(100);
				 }catch(InterruptedException e){}
				 this.name=name;
	     }
		 flag=false;
		 notify();
	   }
   }
   
   public void outPerson(){
      synchronized(this){
	      if(flag){
		     try{
			     wait();
			 }catch(InterruptedException e){}
		  }
		  if(!flag){
		      System.out.println(name + "....." + sex);
		  }
		  flag=true;
		  notify();
	  }
   }
}

class Input implements Runnable{
   int x=0;
   Person p;
   
   Input(Person p){
      this.p=p;
   }
   public void run(){
       while(true){
				   if(x==1){
					  p.setPerson("hjz", "man");
				   }
				   else p.setPerson("哈哈哈", "女女女女");
				   x=(x+1)%2;
	   }
   } 
}

class Output implements Runnable{
   int x=0;
   Person p;
   Output(Person p){
      this.p=p;
   }
   public void run(){
       while(true){
	       p.outPerson();
	   }
   } 
}  


public class Test{
    public static void main(String[] args){
	     Person p = new Person();
		 new Thread(new Input(p)).start();
		 new Thread(new Output(p)).start();
	}
}