本文实例讲述了Java线程间通信不同步问题原理与模拟。分享给大家供大家参考,具体如下: 一 点睛 下面两种情况可造成线程间不同步: 1 生产者没生产完,消费者就来消费。 2 消费者
本文实例讲述了Java线程间通信不同步问题原理与模拟。分享给大家供大家参考,具体如下:
一 点睛
下面两种情况可造成线程间不同步:
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为(张三,男)或(李四,女),但由于生产者还没生产完,就开始消费,所以出现了(张三,女)和(李四,男)的异常输出。
更多java相关内容感兴趣的读者可查看本站专题:《Java进程与线程操作技巧总结》、《Java数据结构与算法教程》、《Java操作DOM节点技巧总结》、《Java文件与目录操作技巧汇总》和《Java缓存操作技巧汇总》
希望本文所述对大家java程序设计有所帮助。