Java线程间通信不同步问题原理与模拟实例

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();
  }
}