producer.java~6~

《深入浅出设计模式》的完整源代码

package threadmediator;

public class Producer extends Thread {
  private Mediator med; // 2. Producers are coupled only to
  private int id; //    the Mediator
  private static int num = 1;
  public Producer (Mediator m) {
    med = m;
    id = num++;
  }
  public void run () {
    int num;
    while (true) {
      med.storeMessage (num = (int) (Math.random () * 100));
      System.out.print ("p" + id + "-" + num + "   ");
      if(med.Count()%5==0)System.out.print("\n");
    }
  }
}