黑马程序员技术交流社区

标题: 关于一个线程安全的问题 [打印本页]
作者: 再见亦是泪    时间: 2013-1-18 20:05
标题: 关于一个线程安全的问题
package ThreadLearn;

class Res
{
        static String Name = "李斯";
        static String Sex = "男";
        static boolean flag = false;
        static Object obj = new Object();
}
class Input implements Runnable
{
        public void run()
        {
               
                for(int x=0; x < 10; x++)
                {
                        synchronized(Res.obj)
                        {
                          if(Res.flag)       
                          {
                                  try{Res.obj.wait();}catch(Exception e){}
                          }
                      if(x%2 == 0)
                      {
                               Res.Name = "麦克。。。。";
                               Res.Sex = "M男。。。。。。。。。";
                      }
                      else
                      {
                             Res.Name = "Lily";
                             Res.Sex = "Female";
                      }
                      Res.flag = false;
                      Res.obj.notifyAll();
                        }
                }
        }
}
class Output implements Runnable
{
        public void run()
        {
                synchronized(Res.obj)
                {
                  for(int i = 0; i < 10 ; i++)
                  {
                         if(!Res.flag)
                         {
                                 try{Res.obj.wait();}catch(Exception e){}
                         }
                       System.out.println(Res.Name+"....."+Res.Sex);
                       Res.flag = true;
                       Res.obj.notifyAll();
                  }
                }
        }
}
public class ThreadLearn3
{

        public static void main(String args[])
        {
                Input input = new Input();
                Output output = new Output();
               
                Thread t1 = new Thread(input);
                Thread t2 = new Thread(output);
               
                t1.start();
                t2.start();
        }
}
作者: 再见亦是泪    时间: 2013-1-18 20:05
我要每个名字轮翻打一次，如这样写就只能一个名字打出来 不能交替 何解
作者: txl    时间: 2013-1-18 20:23
本帖最后由 黑马唐贤来 于 2013-1-18 20:27 编辑
  1. //同学你好,我修改你的代码后实现了你的要求

  3. class Res
  4. {
  5.         static String Name = "李斯";
  6.         static String Sex = "男";
  7.         static boolean flag = false;
  8.         static Object obj = new Object();
  9. }
  10. class Input implements Runnable
  11. {
  12.         public void run()
  13.         {
  14.                
  15.                 for(int x=0; x < 10; x++)
  16.                 {
  17.                         synchronized(Res.obj)
  18.                         {
  19.                           //if(Res.flag)
  20.                                 while(Res.flag)        //这里应该使用while(),这样可以使线程每次被唤醒后都会去检查Res.flag值
  21.                           {
  22.                                   try{Res.obj.wait();}catch(Exception e){}
  23.                           }
  24.                       if(x%2 == 0)
  25.                       {
  26.                                Res.Name = "麦克。。。。";
  27.                                Res.Sex = "M男。。。。。。。。。";
  28.                       }
  29.                       else
  30.                       {
  31.                              Res.Name = "Lily";
  32.                              Res.Sex = "Female";
  33.                       }
  34.                       Res.flag = true;                               //这里修改为true,因为必须要让这个线程执行一遍后wait
  35.                       Res.obj.notifyAll();
  36.                         }
  37.                 }
  38.         }
  39. }
  40. class Output implements Runnable
  41. {
  42.         public void run()
  43.         {
  44.                 synchronized(Res.obj)
  45.                 {
  46.                   for(int i = 0; i < 10 ; i++)
  47.                   {
  48.                          //if(!Res.flag)
  49.                           while(!Res.flag)                                                            //这里使用(!Res.flag)取反来调节线程运行
  50.                          {
  51.                                  try{Res.obj.wait();}catch(Exception e){}
  52.                          }
  53.                        System.out.println(Res.Name+"....."+Res.Sex);
  54.                        Res.flag = false;
  55.                        Res.obj.notifyAll();
  56.                   }
  57.                 }
  58.         }
  59. }
  60. public class Demo2
  61. {

  63.         public static void main(String args[])
  64.         {
  65.                 Input input = new Input();
  66.                 Output output = new Output();
  67.                
  68.                 Thread t1 = new Thread(input);
  69.                 Thread t2 = new Thread(output);
  70.                
  71.                 t1.start();
  72.                 t2.start();
  73.         }
  74. }
  75. 希望共同努力,加油
复制代码
作者: 高浩    时间: 2013-1-18 21:12
//同学你好,我修改你的代码后实现了你的要求

class Res

{

        static String Name = "李斯";

        static String Sex = "男";

        static boolean flag = false;

        static Object obj = new Object();

}

class Input implements Runnable

{

        public void run()

        {

               
                for(int x=0; x < 10; x++)

                {

                        synchronized(Res.obj)

                        {

                          //if(Res.flag)

                                while(Res.flag)        //这里应该使用while(),这样可以使线程每次被唤醒后都会去检查Res.flag值

                          {

                                  try{Res.obj.wait();}catch(Exception e){}

                          }

                      if(x%2 == 0)

                      {

                               Res.Name = "麦克。。。。";

                               Res.Sex = "M男。。。。。。。。。";

                      }

                      else

                      {

                             Res.Name = "Lily";

                             Res.Sex = "Female";

                      }

                      Res.flag = true;                               //这里修改为true,因为必须要让这个线程执行一遍后wait

                      Res.obj.notifyAll();

                        }

                }

        }

}

class Output implements Runnable

{

        public void run()

        {

                synchronized(Res.obj)

                {

                  for(int i = 0; i < 10 ; i++)

                  {

                         //if(!Res.flag)

                          while(!Res.flag)                                                            //这里使用(!Res.flag)取反来调节线程运行

                         {

                                 try{Res.obj.wait();}catch(Exception e){}

                         }

                       System.out.println(Res.Name+"....."+Res.Sex);

                       Res.flag = false;

                       Res.obj.notifyAll();

                  }

                }

        }

}

public class Demo2

{

        public static void main(String args[])

        {

                Input input = new Input();

                Output output = new Output();

               
                Thread t1 = new Thread(input);

                Thread t2 = new Thread(output);

               
                t1.start();

                t2.start();

        }

}
写while循环进行判断是因为线程等待后在此被唤醒会继续它上次的操作继续运行，这样会出现问题，
循环的在让这个线程在判断一次就不会出先错误了，
赋值的任务中没赋值完应该让标识该成true然后判断到true是该线程等待，让输出的线程来执行，输
出线程执行完后在将标识符该为false,在去唤醒等待的赋值线程，如此交替进行，就可以实现你想要
达到的目的了


作者: 再见亦是泪    时间: 2013-1-18 22:19
谢谢，共同努力
作者: 黄金龙    时间: 2013-1-19 11:42
  1. class Res
  2. {
  3.         private        String name        = "李斯";
  4.         private        String Sex = "男";
  5.         private        boolean        flag = false;
  6.         public synchronized void set(String name , String Sex)
  7.         {       
  8.                 while(flag)
  9.                         try{this.wait();}catch(Exception e){};
  10.                 this.name = name;
  11.                 this.Sex = Sex;
  12.                 flag = true;
  13.                 this.notify();
  14.         }

  16.         public synchronized void out ()
  17.         {
  18.                 while(!flag)
  19.                         try{this.wait();}catch(Exception e){};
  20.                 System.out.println(name+"....."+Sex);
  21.                 flag = false;
  22.                 this.notify();
  23.         }
  24. }

  26. class Input implements Runnable
  27. {               
  28.         private Res r;
  29.         Input(Res r)
  30.         {
  31.                 this.r=r;
  32.         }
  33.         public void run()
  34.         {
  35.                 for(int x=0; x < 10; x++)
  36.                 {
  37.                         if(x%2 == 0)
  38.                                 r.set("麦克。。。。","M男。。。。。。。。。");
  39.                         else
  40.                                 r.set("Lily","Female");
  41.                      
  42.                 }
  43.         }
  44. }
  45. class Output implements Runnable
  46. {       
  47.         private Res r;
  48.         Output(Res r)
  49.         {
  50.                 this.r=r;
  51.         }
  52.         public void run()
  53.         {
  54.                 for(int i = 0; i < 10 ; i++)
  55.                         r.out();
  56.         }
  57. }
  58. public class Demo08
  59. {

  61.         public static void main(String args[])
  62.         {
  63.                                 Res r = new Res();
  64.                 Input input = new Input(r);
  65.                 Output output = new Output(r);
  66.                
  67.                 Thread t1 = new Thread(input);
  68.                 Thread t2 = new Thread(output);
  69.                
  70.                 t1.start();
  71.                 t2.start();
  72.         }
  73. }
复制代码

th1111.jpg (14.64 KB, 下载次数: 28)

th1111.jpg




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