CallerThreadExecutor

Class Overview

An executor service that runs each task in the thread that invokes execute/submit.

This applies both to individually submitted tasks and to collections of tasks submitted via invokeAll or invokeAny. In the latter case, tasks will run serially on the calling thread. Tasks are run to completion before a Future is returned to the caller.

The implementation deviates from the ExecutorService specification with regards to the shutdownNow and awaitTermination methods. 1. A call to shutdown or shutdownNow is a no-op. A call to isTerminated always returns false. 2. A call to awaitTermination always returns true immediately. True is returned in order to avoid potential infinite loop in the clients. 3. "best-effort" with regards to canceling running tasks is implemented as "no-effort". No interrupts or other attempts are made to stop threads executing tasks. 4. The returned list will always be empty, as any submitted task is considered to have started execution. This applies also to tasks given to invokeAll or invokeAny which are pending serial execution, including the tasks that have not yet started execution.

Summary

[Expand] Inherited Methods
From class java.util.concurrent.AbstractExecutorService <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> arg0) <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> arg0, long arg1, TimeUnit arg2) <T> T invokeAny(Collection<? extends Callable<T>> arg0) <T> T invokeAny(Collection<? extends Callable<T>> arg0, long arg1, TimeUnit arg2) <T> RunnableFuture<T> newTaskFor(Runnable arg0, T arg1) <T> RunnableFuture<T> newTaskFor(Callable<T> arg0) <T> Future<T> submit(Callable<T> arg0) <T> Future<T> submit(Runnable arg0, T arg1) Future<?> submit(Runnable arg0)
From class java.lang.Object Object clone() boolean equals(Object arg0) void finalize() final Class<?> getClass() int hashCode() final void notify() final void notifyAll() String toString() final void wait(long arg0, int arg1) final void wait(long arg0) final void wait()
From interface java.util.concurrent.Executor abstract void execute(Runnable arg0)
From interface java.util.concurrent.ExecutorService abstract boolean awaitTermination(long arg0, TimeUnit arg1) abstract <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> arg0) abstract <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> arg0, long arg1, TimeUnit arg2) abstract <T> T invokeAny(Collection<? extends Callable<T>> arg0) abstract <T> T invokeAny(Collection<? extends Callable<T>> arg0, long arg1, TimeUnit arg2) abstract boolean isShutdown() abstract boolean isTerminated() abstract void shutdown() abstract List<Runnable> shutdownNow() abstract <T> Future<T> submit(Callable<T> arg0) abstract <T> Future<T> submit(Runnable arg0, T arg1) abstract Future<?> submit(Runnable arg0)