黑马程序员技术交流社区

标题: 毕老师第12天视频,多线程同步,求帮助 [打印本页]

作者: 邝雄伟    时间: 2012-12-5 21:34
标题: 毕老师第12天视频,多线程同步,求帮助
想了一个晚上都不明白,按照以下代码为什么会重复打印man或者重复打印女女女女女女,按理说不是轮流打印吗,求解析,万分感激


class InperOurperDemo
{
        public static void main(String[] args)
        {
                Res r = new Res();
                Thread t1 = new Thread(new Inper(r));
                Thread t2 = new Thread(new Ourper(r));
                t1.start();
                t2.start();
        }
}

class Res
{
        String name;
        String sex;
        boolean flag;
}

class Inper implements Runnable
{
        private Res r;
        Inper(Res r)
        {
                this.r = r;
        }
        public void run()
        {
                int x=0;
                while(true)
                {
                        if (r.flag)
                                {
                                try{r.wait();} catch(Exception e){}
                                }
                        synchronized(r)
                        {
                                if (x==0)
                                {
                                        r.name="mike";
                                        r.sex="man";
                                }
                                else
                                {
                                        r.name= "丽丽";
                                        r.sex= "女女女女女女";
                                }
                                x=(x+1)%2;
                                
                                r.flag = true;
                                r.notify();
                        }
                }
        }
}

class Ourper implements Runnable
{
        private Res r;
        
        Ourper(Res r)
        {
                this.r = r;
        }
        public void run()
        {
               
                while(true)
                {
                        if(!r.flag)
                                {
                                        try{r.wait();}catch(Exception e){}
                                }
                        synchronized(r)
                        {
                                System.out.println(r.name+"........"+r.sex);
                                r.flag = false;
                                r.notify();
                        }
                }
        }
}
作者: 丁桂松    时间: 2012-12-6 00:29
指向的是2个对象.不是同一个对象.无法获得多线程并发访问.无法交替打印.必须是按顺序结构执行语句.
作者: 李培根    时间: 2012-12-6 07:36
class InperOurperDem
{
         public static void main(String[] args)
        {
                 Res r = new Res();
                 Thread t1 = new Thread(new Inper(r));
                 Thread t2 = new Thread(new Ourper(r));
                 t1.start();
                 t2.start();
        }
}

class Res
{
         String name;
         String sex;
         boolean flag;
}

class Inper implements Runnable
{
         private Res r;
         Inper(Res r)
         {
                 this.r = r;
         }
         public void run()
         {
                 int x=0;
                 while(true)
                 {
                         synchronized(r){  
                                                if (r.flag) //要定义在同步中,因为要明确操作的是哪个锁上的线程
                                         {
                                         try{r.wait();} catch(Exception e){}
                                         }
                                 
                                 
                                         if (x==0)
                                         {
                                         r.name="mike";
                                         r.sex="man";
                                         }
                                         else
                                         {
                                                 r.name= "丽丽";
                                                 r.sex= "女女女女女女";
                                         }
                                         x=(x+1)%2;
                                 
                                         r.flag = true;
                                         r.notify();
                         }
                 }
         }
}

class Ourper implements Runnable
{
     private Res r;
     
     Ourper(Res r)
     {
             this.r = r;
     }
     public void run()
     {
            
        while(true)
         {
                synchronized(r)
            {
                 if(!r.flag) //同理:要定义在同步中,因为要明确操作的是哪个锁上的线程

                 {
                     try{r.wait();}catch(Exception e){}
                 }
                 
                 System.out.println(r.name+"........"+r.sex);
                 r.flag = false;
                 r.notify();
            }
         }
     }
}

wait  notify  notify这些方法都必须定义在同步中,因为这些是操作线程的防线,必须要明确操作的是哪个锁上的线程。
作者: 焦健    时间: 2012-12-6 21:30
class InperOurperDemo
{
        public static void main(String[] args)
        {
                Res r = new Res();
                Thread t1 = new Thread(new Inper(r));
                Thread t2 = new Thread(new Ourper(r));
                t1.start();
                t2.start();
        }
}

class Res
{
        String name;
        String sex;
        boolean flag;
}

class Inper implements Runnable
{
        private Res r;
        Inper(Res r)
        {
                this.r = r;
        }
        public void run()
        {
                int x=0;
                while(true)
                        {
                                     synchronized(r)//注意要把锁定在if判断语句以外,while循环中的内容都需要上锁同步
                                     {
                                            
                                        if (r.flag)
                                                {
                                                try{r.wait();} catch(Exception e){}
                                                }
                        
                                if (x==0)
                                {
                                        r.name="mike";
                                        r.sex="man";
                                }
                                else
                                {
                                        r.name= "丽丽";
                                        r.sex= "女女女女女女";
                                }
                                x=(x+1)%2;
                                
                                r.flag = true;
                                r.notify();
                        }
                }
        }
}

class Ourper implements Runnable
{
        private Res r;
        
        Ourper(Res r)
        {
                this.r = r;
        }
        public void run()
        {
               
                while(true)
                {
                                synchronized(r)//while循环中的内容都需要上锁同步
                            {
                                                if(!r.flag)
                                        {
                                        try{r.wait();}catch(Exception e){}
                                        }
                        
                                System.out.println(r.name+"........"+r.sex);
                                r.flag = false;
                                r.notify();
                        }
                }
        }
}
注意:while循环中的内容都需要同步,要把锁上在所有需要同步的语句以外。
作者: 焦健    时间: 2012-12-6 21:30
class InperOurperDemo
{
        public static void main(String[] args)
        {
                Res r = new Res();
                Thread t1 = new Thread(new Inper(r));
                Thread t2 = new Thread(new Ourper(r));
                t1.start();
                t2.start();
        }
}

class Res
{
        String name;
        String sex;
        boolean flag;
}

class Inper implements Runnable
{
        private Res r;
        Inper(Res r)
        {
                this.r = r;
        }
        public void run()
        {
                int x=0;
                while(true)
                        {
                                     synchronized(r)//注意要把锁定在if判断语句以外,while循环中的内容都需要上锁同步
                                     {
                                            
                                        if (r.flag)
                                                {
                                                try{r.wait();} catch(Exception e){}
                                                }
                        
                                if (x==0)
                                {
                                        r.name="mike";
                                        r.sex="man";
                                }
                                else
                                {
                                        r.name= "丽丽";
                                        r.sex= "女女女女女女";
                                }
                                x=(x+1)%2;
                                
                                r.flag = true;
                                r.notify();
                        }
                }
        }
}

class Ourper implements Runnable
{
        private Res r;
        
        Ourper(Res r)
        {
                this.r = r;
        }
        public void run()
        {
               
                while(true)
                {
                                synchronized(r)//while循环中的内容都需要上锁同步
                            {
                                                if(!r.flag)
                                        {
                                        try{r.wait();}catch(Exception e){}
                                        }
                        
                                System.out.println(r.name+"........"+r.sex);
                                r.flag = false;
                                r.notify();
                        }
                }
        }
}
注意:while循环中的内容都需要同步,要把锁上在所有需要同步的语句以外。
作者: 焦健    时间: 2012-12-6 21:36
class InperOurperDemo
{
        public static void main(String[] args)
        {
                Res r = new Res();
                Thread t1 = new Thread(new Inper(r));
                Thread t2 = new Thread(new Ourper(r));
                t1.start();
                t2.start();
        }
}

class Res
{
        String name;
        String sex;
        boolean flag;
}

class Inper implements Runnable
{
        private Res r;
        Inper(Res r)
        {
                this.r = r;
        }
        public void run()
        {
                int x=0;
                while(true)
                        {
                                     synchronized(r)//注意要把锁定在if判断语句以外,while循环中的内容都需要上锁同步
                                     {
                                            
                                        if (r.flag)
                                                {
                                                try{r.wait();} catch(Exception e){}
                                                }
                        
                                if (x==0)
                                {
                                        r.name="mike";
                                        r.sex="man";
                                }
                                else
                                {
                                        r.name= "丽丽";
                                        r.sex= "女女女女女女";
                                }
                                x=(x+1)%2;
                                
                                r.flag = true;
                                r.notify();
                        }
                }
        }
}

class Ourper implements Runnable
{
        private Res r;
        
        Ourper(Res r)
        {
                this.r = r;
        }
        public void run()
        {
               
                while(true)
                {
                                synchronized(r)//while循环中的内容都需要上锁同步
                            {
                                                if(!r.flag)
                                        {
                                        try{r.wait();}catch(Exception e){}
                                        }
                        
                                System.out.println(r.name+"........"+r.sex);
                                r.flag = false;
                                r.notify();
                        }
                }
        }
}
注意:while循环中的内容都需要同步,要把锁上在所有需要同步的语句以外。
作者: 焦健    时间: 2012-12-6 21:37
class InperOurperDemo
{
        public static void main(String[] args)
        {
                Res r = new Res();
                Thread t1 = new Thread(new Inper(r));
                Thread t2 = new Thread(new Ourper(r));
                t1.start();
                t2.start();
        }
}

class Res
{
        String name;
        String sex;
        boolean flag;
}

class Inper implements Runnable
{
        private Res r;
        Inper(Res r)
        {
                this.r = r;
        }
        public void run()
        {
                int x=0;
                while(true)
                        {
                                     synchronized(r)//注意要把锁定在if判断语句以外,while循环中的内容都需要上锁同步
                                     {
                                            
                                        if (r.flag)
                                                {
                                                try{r.wait();} catch(Exception e){}
                                                }
                        
                                if (x==0)
                                {
                                        r.name="mike";
                                        r.sex="man";
                                }
                                else
                                {
                                        r.name= "丽丽";
                                        r.sex= "女女女女女女";
                                }
                                x=(x+1)%2;
                                
                                r.flag = true;
                                r.notify();
                        }
                }
        }
}

class Ourper implements Runnable
{
        private Res r;
        
        Ourper(Res r)
        {
                this.r = r;
        }
        public void run()
        {
               
                while(true)
                {
                                synchronized(r)//while循环中的内容都需要上锁同步
                            {
                                                if(!r.flag)
                                        {
                                        try{r.wait();}catch(Exception e){}
                                        }
                        
                                System.out.println(r.name+"........"+r.sex);
                                r.flag = false;
                                r.notify();
                        }
                }
        }
}
注意:while循环中的内容都需要同步,要把锁上在所有需要同步的语句以外。




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