@Test
    public void testPut() throws InterruptedException {
        Receiver<String> receiver = new Receiver<>();
        Worker runnable = new Worker(receiver, 0);
        Thread worker = new Thread(runnable);
        worker.start();
        Tuple2<Receiver.MessageState, String> answer = receiver.get(1000L * 1000L * 1000L);
        assertEquals(Receiver.MessageState.VALID, answer.first);
        assertEquals(answer.second, Worker.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