!747 !named thread m { static new LinkedBlockingQueue queue; static new L done; p { thread "Executor" { for (S input : iterateOverBlockingQueue(queue)) process(input); } } static void process(S input) { // TODO } }