import java.util.concurrent.BlockingQueue; class Worker { static String awaitResult(BlockingQueue<String> results) { try { return results.take(); } catch (InterruptedException ignored) { return "timeout"; } } }