consumer.java

来自「《深入浅出设计模式》的完整源代码」· Java 代码 · 共 17 行

package threadmediator;

public class Consumer extends Thread {
  private Mediator med; //消费者(信息接收者)也仅仅连接中介者
  private int id;
  private static int num = 1;
  public Consumer (Mediator m) {
    med = m;
    id = num++;
  }
  public void run () {
    while (true) {
      //显示信息生产者的ID及其信息
      System.out.print ("c" + id + "-" + med.retrieveMessage () + "   ");
    }
  }
}