@Test
public void burnsAllTasksInQueue() throws Exception {

  runnables.offer(() -> messages.add("hello"));
  runnables.offer(() -> messages.add("world"));
  taskRunner.run();
  await().atMost(500, MILLISECONDS).until(runnables::isEmpty);
  assertThat(messages, contains("hello", "world"));
}