running = false; if (waker != null) waker.interrupt();
  public void stop()  {    running = false;    if (waker != null)      waker.interrupt();    synchronized (queueLock)      {        queue = 0;      }  }