ForgettingExecutor

ForgettingExecutor.java

public class ForgettingExecutor
{
    private ForgettingExecutor() { }

    public static <T> Future<T> submit(ExecutorService executor, Callable<T> callable)
    {
        return executor.submit(new ForgettingCallable<>(new AtomicReference<>(callable)));
    }

    private static class ForgettingCallable<T> implements Callable<T>
    {
        private final AtomicReference<Callable<T>> callable;

        public ForgettingCallable(AtomicReference<Callable<T>> callable)
        {
            this.callable = callable;
        }

        @Override
        public T call() throws Exception
        {
            try {
                return callable.get().call();
            } finally {
                callable.set(null);
            }
        }
    }
}