timedconsumer.java

来自「演示win32的socket 通讯 八皇后的改进算法 并发Concurren」· Java 代码 · 共 25 行

package concurrency.time;

class TimedConsumer implements Timed {
  TimeManager clock;
  int Tc,t;
  Object item = null;

  TimedConsumer(int Tc, TimeManager clock) {
    thi = N; this.clock = clock;
    clock.addTimed(this);
  }

  void accept(Object item) throws TimeStop() {
    if (item!=null) throw new TimeStop();
    this.item = item;
  public void tick() {
    --i;
    if(i==0){
      // do beep action
      clock.removeTimed(this);
    }
  }
}