这个线程安全应如何解决? - 黑马程序员技术交流社区

class ResourceWaitNotifyDemo //
{
private String name;
private String sex;
private boolean flag=false;
public synchronized void setInfo(String name,String sex)//信息输入函数
{
if(flag)
/*如果flag值为false，则共享资源中没有信息，进行赋值
如果为true,则共享资源中有信息没有打印，不进行赋值，进行wait操作
*/
{
try
{
this.name = name;
this.sex = sex;
this.wait();
}
catch (Exception e)
{
}
}else{
}
flag=true; //改变开关，让输入程序不能再次进行赋值，同时可以让打印程序启动
this.notify();//唤醒输出线程
}
public synchronized void OutInfo()//信息输出函数
{
if (!flag)//如果flag值为ture，则共享资源中有信息，进行打印，否则等待
{
try
{
System.out.println(name+"......"+sex);
this.wait();
}
catch (Exception e)
{
}
}
else{
}
flag=false; //改变开关，让输入程序可以进行赋值，同时让自己不能在打印
this.notify();//唤醒输入线程
}
}
/*输入线程*/
class InputWaitNotifyDemo implements Runnable
{
private ResourceWaitNotifyDemo r; //创建共享类引用
InputWaitNotifyDemo(ResourceWaitNotifyDemo r)
{
this.r = r; //接收共享类对象
}
public void run()
{
int x=0;
while(true)
{
if (x==0)
{
r.setInfo("mike","man");
}
else
{
r.setInfo("莉莉","女女女女女");
}
x=(x+1)%2;
}
}
}
/*输出线程*/
class OutputWaitNotifyDemo implements Runnable
{
private ResourceWaitNotifyDemo r;
OutputWaitNotifyDemo(ResourceWaitNotifyDemo r)
{
this.r = r; //和输入线程操作同一个共享类对象
}
public void run()
{
while (true)
{
r.OutInfo();
}
}
}
/*主函数*/
class ThreadWaitNotifyTest
{
public static void main(String[] args)
{
ResourceWaitNotifyDemo res = new ResourceWaitNotifyDemo();
/*
InputWaitNotifyDemo i = new InputWaitNotifyDemo(res);
OutputWaitNotifyDemo o = new OutputWaitNotifyDemo(res);
Thread t1 = new Thread(i);
Thread t2 = new Thread(o);
t1.start();
t2.start();
*/
new Thread(new InputWaitNotifyDemo(res)).start(); //创建输入线程
new Thread(new OutputWaitNotifyDemo(res)).start(); //创建打印线程
}
}

复制代码