黑马程序员技术交流社区

标题: 关于多线程之间通信的问题 [打印本页]

---

作者: 黑马任雪刚    时间: 2012-5-17 19:58
标题: 关于多线程之间通信的问题
//关于线程之间通信的小程序
//一个线程负责存姓名和性别，而另一个线程负责取姓名和性别。


//问题：怎么我的运行结果老是“丽丽------女”呢？？？？？？？？？？？？
class res
{
String name;
String sex;
boolean flag=false;
}
class Input implements Runnable
{
private res r;
Input(res r)
{
  this.r=r;
}
public void run()
{
  while(true)
  {
   synchronized(r)
   {
    if(r.flag)
    try{r.wait();}catch(Exception e){}
  int x=0;
  if(x==0)
  {
   r.name="丽丽";
   r.sex="女";
  
  }
  else
  {
   r.name="mike";
   r.sex="man";
  }
  x=(x+1)%2;
  r.flag=true;
  r.notify();
   }
  }
}
}
class Output implements Runnable
{
private res r;
Output(res r)
{
  this.r=r;
}
public void run()
{
  while(true)
   synchronized(r)
   {
   if(!r.flag)
    try{r.wait();}catch(Exception e){}//wait()的是持有r锁的线程
   System.out.println(r.name+"-------"+r.sex);
   r.flag=false;
   r.notify();
}
}
}
public class OutIntputDemo
{

public static void main(String[] args)
{
  res r=new res();
     new Thread(new Input(r)).start();
     new Thread(new Output(r)).start();
}
}

---

作者: 韩国军    时间: 2012-5-17 22:58
wait:
notify();
notifyAll();

都使用在同步中，因为要对持有监视器(锁)的线程操作。
所以要使用在同步中，因为只有同步才具有锁。

因为这些方法在操作同步中线程时，都必须要标识它们所操作线程只有的锁，
只有同一个锁上的被等待线程，可以被同一个锁上notify唤醒。
不可以对不同锁中的线程进行唤醒。

也就是说，等待和唤醒必须是同一个锁。

而锁可以是任意对象，所以可以被任意对象调用的方法定义Object类中。

class Res
{
        private String name;
        private String sex;
        private boolean flag = false;

        public synchronized void set(String name,String sex)
        {
                if(flag)
                        try{this.wait();}catch(Exception e){}
                this.name = name;
               
                this.sex = sex;
                flag = true;
                this.notify();
        }
        public synchronized void out()
        {
                if(!flag)
                        try{this.wait();}catch(Exception e){}
                System.out.println(name+"........"+sex);
                flag = false;
                this.notify();
        }
}

class Input implements Runnable
{
        private Res r ;
        Input(Res r)
        {
                this.r = r;
        }
        public void run()
        {
                int x = 0;
                while(true)
                {
                        if(x==0)                               
                                r.set("mike","man");                               
                        else       
                                r.set("丽丽","女女女女女");                               
                        x = (x+1)%2;
                }
        }
}

class Output implements Runnable
{
        private Res r ;
       
        Output(Res r)
        {
                this.r = r;
        }
        public void run()
        {
                while(true)
                {
                        r.out();
                }
        }
}


class  InputOutputDemo2
{
        public static void main(String[] args)
        {
                Res r = new Res();

                new Thread(new Input(r)).start();
                new Thread(new Output(r)).start();
        }
}
这样写就不会出问题了

---

作者: 潘东升    时间: 2012-5-17 23:11
int x = 0;
把这个放到run方法的上面去吧，你放在这里就每次x==0都为真，当然就只执行if里面的语句了，哈

---

欢迎光临 黑马程序员技术交流社区 (http://bbs.itheima.com/)

黑马程序员IT技术论坛 X3.2