jdk.util.concurrent.AbstractExecutorService
Provides default implementations of ExecutorService execution methods. This class implements the submit, invokeAny and invokeAll methods using a RunnableFuture returned by newTaskFor, which defaults to the FutureTask class provided in this package. For example, the implementation of submit(Runnable) creates an associated RunnableFuture that is executed and returned. Subclasses may override the newTaskFor methods to return RunnableFuture implementations other than FutureTask.
Extension example. Here is a sketch of a class that customizes ThreadPoolExecutor to use a CustomTask class instead of the default FutureTask:
public class CustomThreadPoolExecutor extends ThreadPoolExecutor {
static class CustomTask<V> implements RunnableFuture<V> {...}
protected <V> RunnableFuture<V> newTaskFor(Callable<V> c) { return new CustomTask<V>(c); } protected <V> RunnableFuture<V> newTaskFor(Runnable r, V v) { return new CustomTask<V>(r, v); } // ... add constructors, etc. }
Provides default implementations of ExecutorService
execution methods. This class implements the submit,
invokeAny and invokeAll methods using a
RunnableFuture returned by newTaskFor, which defaults
to the FutureTask class provided in this package. For example,
the implementation of submit(Runnable) creates an
associated RunnableFuture that is executed and
returned. Subclasses may override the newTaskFor methods
to return RunnableFuture implementations other than
FutureTask.
Extension example. Here is a sketch of a class
that customizes ThreadPoolExecutor to use
a CustomTask class instead of the default FutureTask:
public class CustomThreadPoolExecutor extends ThreadPoolExecutor {
static class CustomTask<V> implements RunnableFuture<V> {...}
protected <V> RunnableFuture<V> newTaskFor(Callable<V> c) {
return new CustomTask<V>(c);
}
protected <V> RunnableFuture<V> newTaskFor(Runnable r, V v) {
return new CustomTask<V>(r, v);
}
// ... add constructors, etc.
}invoke-allclj
(invoke-all this tasks)(invoke-all this tasks timeout unit)Description copied from interface: ExecutorService
tasks - the collection of tasks - java.util.Collection
timeout - the maximum time to wait - long
unit - the time unit of the timeout argument - java.util.concurrent.TimeUnit
returns: a list of Futures representing the tasks, in the same
sequential order as produced by the iterator for the
given task list. If the operation did not time out,
each task will have completed. If it did time out, some
of these tasks will not have completed. - <T> java.util.List<java.util.concurrent.Future<T>>
throws: java.lang.InterruptedException - if interrupted while waiting, in which case unfinished tasks are cancelled
Description copied from interface: ExecutorService
tasks - the collection of tasks - `java.util.Collection`
timeout - the maximum time to wait - `long`
unit - the time unit of the timeout argument - `java.util.concurrent.TimeUnit`
returns: a list of Futures representing the tasks, in the same
sequential order as produced by the iterator for the
given task list. If the operation did not time out,
each task will have completed. If it did time out, some
of these tasks will not have completed. - `<T> java.util.List<java.util.concurrent.Future<T>>`
throws: java.lang.InterruptedException - if interrupted while waiting, in which case unfinished tasks are cancelledinvoke-anyclj
(invoke-any this tasks)(invoke-any this tasks timeout unit)Description copied from interface: ExecutorService
tasks - the collection of tasks - java.util.Collection
timeout - the maximum time to wait - long
unit - the time unit of the timeout argument - java.util.concurrent.TimeUnit
returns: the result returned by one of the tasks - <T> T
throws: java.lang.InterruptedException - if interrupted while waiting
Description copied from interface: ExecutorService tasks - the collection of tasks - `java.util.Collection` timeout - the maximum time to wait - `long` unit - the time unit of the timeout argument - `java.util.concurrent.TimeUnit` returns: the result returned by one of the tasks - `<T> T` throws: java.lang.InterruptedException - if interrupted while waiting
submitclj
(submit this task)(submit this task result)Description copied from interface: ExecutorService
task - the task to submit - java.lang.Runnable
result - the result to return - T
returns: a Future representing pending completion of the task - <T> java.util.concurrent.Future<T>
throws: java.util.concurrent.RejectedExecutionException - if the task cannot be scheduled for execution
Description copied from interface: ExecutorService task - the task to submit - `java.lang.Runnable` result - the result to return - `T` returns: a Future representing pending completion of the task - `<T> java.util.concurrent.Future<T>` throws: java.util.concurrent.RejectedExecutionException - if the task cannot be scheduled for execution
cljdoc is a website building & hosting documentation for Clojure/Script libraries
× close