/*
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();
}
}