线程间通信不同步问题模拟

我就是我 2021-09-29 14:06 307阅读 0赞

**一 点睛**

下面两种情况可造成线程间不同步：

1 生产者没生产完，消费者就来消费。

2 消费者没消费完，生产者又来生产，覆盖了还没来得及消费的数据。

**二 代码**

class Producer implements Runnable
    {
        private Person person = null;
        public Producer( Person person )
        {
            this.person = person;
        }
        @Override
        public void run()
        {
            for( int i = 0; i < 20; ++i )
            {
                if( i % 2 == 0 )
                {
                    person.setName("张三");
                    try{
                        Thread.sleep(1000);
                    } catch (InterruptedException e){
                        e.printStackTrace();
                    }
                    person.setSex("男");
                }
                else
                {
                    person.setName("李四");
                    try{
                        Thread.sleep(1000);
                    } catch (InterruptedException e){
                    e.printStackTrace();
                    }
                    person.setSex("女");
                }
            }
        }
    }
    class Consumer implements Runnable
    {
        private Person person = null;
        public Consumer( Person person )
        {
            this.person = person;
        }
        @Override
        public void run()
        {
            for( int i = 0; i < 20; ++i  )
            {
                System.out.println( person.getName( ) + " ---->" + person.getSex( )  );
                try{
                    Thread.sleep(1000);
                } catch (InterruptedException e){
                    e.printStackTrace();
                }
            }
        }
    }
    class Person
    {
        private String name;
        private String sex;
        
       Person (String name, String sex)
        {
            this.name = name;
            this.sex  = sex;       
        }
        public String getName( )
        {
            return name;
        }
        public String getSex( )
        {
            return sex;
        }
        public void setName(String name)
        {
            this.name = name;
        }
        public void setSex(String sex)
        {
            this.sex = sex;
        }
    }
    public class ThreadCommunation
    {
        public static void main( String[] args )
        {
            Person person = new Person("李四", "女");
            new Thread( new Producer( person ) ).start();
            new Thread( new Consumer( person ) ).start();
        }
    }

**三 运行**

张三 ---->女
    张三 ---->男
    李四 ---->男
    李四 ---->男
    张三 ---->女
    李四 ---->男
    张三 ---->女
    李四 ---->男
    张三 ---->女
    张三 ---->女
    李四 ---->男
    李四 ---->男
    李四 ---->男
    张三 ---->男
    李四 ---->男
    李四 ---->男
    张三 ---->女
    张三 ---->男
    李四 ---->男
    张三 ---->男

**四 说明**

程序的意图是设置person为（张三，男）或（李四，女），但由于生产者还没生产完，就开始消费，所以出现了（张三，女）和（李四，男）的异常输出。