CustomStopWatch.java

public class CustomStopWatch implements Runnable {

  private final long timeoutMs;
  private final TimeoutCallBack callBack;
  private AtomicBoolean eventTriggered = new AtomicBoolean(false);

  public CustomStopWatch(TimeoutCallBack callBack, long timeoutMs) {
    this.callBack = callBack;
    this.timeoutMs = timeoutMs;
  }

  @Override
  public void run() {
    try {
      waitUntilTimeout();
    } catch (InterruptedException e) {
      throw new IllegalStateException("IE thrown ", e);
    }
  }

  private synchronized void waitUntilTimeout() throws InterruptedException {
    while(true) {
      eventTriggered.set(false);
      this.wait(timeoutMs);
      if(!eventTriggered.get()){
        callBack.onTimeout();
        // what to do
        break;
      } else {
        // go back to wait again
      }
    }
  }

  public synchronized void triggerEvent(){
    eventTriggered.set(true);
    this.notifyAll();
  }

  interface TimeoutCallBack {
    void onTimeout();
  }

}