@Override
    public void run() {
      while (true) {
        Runnable r = poll();
        if (r != null) r.run();
        else if (!closed) TimeoutUtil.sleep(1);
        else {
          break;
        }
      }
    }
@Override
    public void run()