@@ -0,0 +1,1030 @@
+package com.yahoo.concurrent;%0A%0Aimport java.util.Collections;%0Aimport java.util.List;%0Aimport java.util.concurrent.AbstractExecutorService;%0Aimport java.util.concurrent.ExecutorService;%0Aimport java.util.concurrent.TimeUnit;%0A%0A/**%0A * %7B@link ExecutorService%7D implementation that runs all tasks in the calling thread. Useful for tests.%0A *%0A * @author jonmv%0A */%0Apublic class InThreadExecutorService extends AbstractExecutorService %7B%0A%0A    private boolean isShutdown = false;%0A%0A    @Override%0A    public void shutdown() %7B%0A        isShutdown = true;%0A    %7D%0A%0A    @Override%0A    public List%3CRunnable%3E shutdownNow() %7B%0A        shutdown();%0A        return Collections.emptyList();%0A    %7D%0A%0A    @Override%0A    public boolean isShutdown() %7B%0A        return isShutdown;%0A    %7D%0A%0A    @Override%0A    public boolean isTerminated() %7B%0A        return isShutdown;%0A    %7D%0A%0A    @Override%0A    public boolean awaitTermination(long timeout, TimeUnit unit) %7B%0A        return true;%0A    %7D%0A%0A    @Override%0A    public void execute(Runnable command) %7B%0A        command.run();%0A    %7D%0A%0A%7D%0A

Add InThreadExecutorService for test purposes