public void run( ){

    System.out.println("Producer "+threadID+" starts.");
    yield( );

    for ( int j = 0; j < steps; j++)
    {
      byte  m;

      m = get_message( );
      buffer.deposit(m, threadID, j);     
      yield( );      
    }
    System.out.println("Producer "+threadID+" terminates.");
   
  }