黑马程序员技术交流社区

标题: 线程间通信 妖疑惑 [打印本页]
作者: 董月峰    时间: 2014-1-9 10:52
标题: 线程间通信 妖疑惑
/*
* 线程间的通讯：
* 其实就是多个线程在操作同一个资源
* 但是操作的动作不同。
说明下疑惑的问题，synchronized（Input。class）能解决妖的问题，但是改成r后运行还有妖，代码就是课上讲的，如下。大神帮忙看下是什么原因
*/

class Res
{
        String name;
        String sex;
}

class Input implements Runnable
{
        private Res r;
        Input(Res r)
        {
                this.r=r;
        }
        public void run()
        {
                int x=0;
                while(true)
                {
                        synchronized(r)//2个以上线程？用的一个锁？
                        {
                                if(x==0)
                                {
                                        r.name="mike";
                                        r.sex="man";
                                }
                                else
                                {
                                        r.name="小丽";
                                        r.sex="女";
                                }
                                x=(x+1)%2;
                        }
                }
        }
}
class Output implements Runnable
{
        private Res r;
        Output(Res r)
        {
                this.r=r;
        }
        public void run()
        {
                while(true)
                {
                        synchronized(r)
                        {
                                System.out.println(r.name+"--------"+r.sex);
                        }
                }
        }
}

public class InputOutputDemo
{
        public static void main(String[] args)
        {
                Res r=new Res();
               
                Input in=new Input(r);
                Output out=new Output(r);
               
                Thread t1=new Thread(in);
                Thread t2=new Thread(out);
               
                t1.start();
                t2.start();
        }
}
作者: 伍艳雄    时间: 2014-1-9 12:57
  1. class Res
  2. {
  3.         String name;
  4.         String sex;
  5.         boolean flag = false;
  6. }

  8. class Input implements Runnable
  9. {
  10.         private Res r ;
  11.         Input(Res r)
  12.         {
  13.                 this.r = r;
  14.         }
  15.         public void run()
  16.         {
  17.                 int x = 0;
  18.                 while(true)
  19.                 {
  20.                         synchronized(r)
  21.                         {

  23.                                 if(r.flag)
  24.                                         try{r.wait();}catch(Exception e){}
  25.                                 if(x==0)
  26.                                 {
  27.                                         r.name="mike";
  28.                                         r.sex="man";
  29.                                 }
  30.                                 else
  31.                                 {
  32.                                         r.name="丽丽";
  33.                                         r.sex = "女女女女女";
  34.                                 }
  35.                                 x = (x+1)%2;
  36.                                 r.flag = true;
  37.                                 r.notify();
  38.                         }
  39.                 }
  40.         }
  41. }

  43. class Output implements Runnable
  44. {
  45.         private Res r ;
  46.        
  47.         Output(Res r)
  48.         {
  49.                 this.r = r;
  50.         }
  51.         public void run()
  52.         {
  53.                 while(true)
  54.                 {
  55.                         synchronized(r)
  56.                         {
  57.                                 if(!r.flag)
  58.                                         try{r.wait();}catch(Exception e){}
  59.                                 System.out.println(r.name+"...."+r.sex);
  60.                                 r.flag = false;
  61.                                 r.notify();
  62.                         }
  63.                 }
  64.         }
  65. }


  68. class  InputOutputDemo
  69. {
  70.         public static void main(String[] args)
  71.         {
  72.                 Res r = new Res();

  74.                 Input in = new Input(r);
  75.                 Output out = new Output(r);

  77.                 Thread t1 = new Thread(in);
  78.                 Thread t2 = new Thread(out);

  80.                 t1.start();
  81.                 t2.start();
  82.         }
  83. }
复制代码


加唤醒机制.



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