@Override
        public void run() {
            try {
                Thread.sleep(timeToWait);
            } catch (InterruptedException e) {
                fail("Test was interrupted.");
            }
            receiver.put(HELLO_WORLD);
        }
Check for com.yahoo.concurrent.Receiver.

@author <a href="mailto:steinar@yahoo-inc.com">Steinar Knutsen</a>
vespajlib/src/test/java/com/yahoo/concurrent/ReceiverTestCase.java