import java.util.concurrent.ExecutionException;
import java.util.concurrent.FutureTask;
import java.util.concurrent.TimeUnit;
import java.util.function.Supplier;

public class ExclusiveCacheAccessingWorker implements Runnable, Stoppable, AsyncCacheAccess {
    private final BlockingQueue<Runnable> workQueue;
    private final String displayName;
    private final ExclusiveCacheAccessCoordinator cacheAccess;

    ExclusiveCacheAccessCoordinator cacheAccess
    ExclusiveCacheAccessingWorker cacheAccessWorker

    def setup() {
        cacheAccess = Stub(ExclusiveCacheAccessCoordinator) {
            useCache(_) >> { Runnable action -> action.run() }
        }
        cacheAccessWorker = new ExclusiveCacheAccessingWorker("<cache>", cacheAccess)
    }

    def "read runs after queued writes are processed"() {

    private final AbstractCrossProcessCacheAccess crossProcessCacheAccess;
    private final CacheAccessOperationsStack operations;

    private ManagedExecutor cacheUpdateExecutor;
    private ExclusiveCacheAccessingWorker cacheAccessWorker;
    private final Lock stateLock = new ReentrantLock(); // protects the following state
    private final Condition condition = stateLock.newCondition();

    private boolean open;