sharedobjectconsumer.java

来自「java 完全探索的随书源码」· Java 代码 · 共 30 行

public class SharedObjectConsumer extends Thread
{
  // The reference to the shared data
  SharedObject sharedObject = null;
  // How many reads of the shared data should happen
  int numberOfReads = 0;

  public SharedObjectConsumer( SharedObject obj, int numberOfTimesToRead )
  {
    super();
    sharedObject = obj;
    numberOfReads = numberOfTimesToRead;
  }

  private int getNumberOfReads()
  {
    return numberOfReads;
  }

  public void run()
  {
    int maxCounter = getNumberOfReads();
    for( int counter = 1; counter <= maxCounter; counter++ )
    {
      Integer intObj = sharedObject.getSharedData();
      System.out.println( "Consumer - Getting New Value: " + intObj.intValue() );
    }
  }
}