code: public void run() {
      Thread.currentThread().setPriority(Thread.NORM_PRIORITY);
      while( true ) {
        try {
          RPC t = PENDING.take();
          // One-shot timeout effect.  Retries need to re-insert back in the queue
          if( H2O.CLOUD.contains(t._target) ) {
            if( !t.isDone() ) t.call();
          } else t.cancel(true);
        } catch( InterruptedException e ) {
          // Interrupted while waiting for a packet?
          // Blow it off and go wait again...
        }
      }
    }
docs: Started by main() on a single thread, handle timing-out UDP packets