Package org.apache.sysds.runtime.util
Class CommonThreadPool
- java.lang.Object
- 
- org.apache.sysds.runtime.util.CommonThreadPool
 
- 
- All Implemented Interfaces:
- Executor,- ExecutorService
 
 public class CommonThreadPool extends Object implements ExecutorService This common thread pool provides an abstraction to obtain a shared thread pool, specifically the ForkJoinPool.commonPool, for all requests of the maximum degree of parallelism. If pools of different size are requested, we create new pool instances of FixedThreadPool.
- 
- 
Field SummaryFields Modifier and Type Field Description static ExecutorServicetriggerRemoteOPsPool
 - 
Constructor SummaryConstructors Constructor Description CommonThreadPool(ExecutorService pool)
 - 
Method SummaryAll Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description booleanawaitTermination(long timeout, TimeUnit unit)voidexecute(Runnable command)static ExecutorServiceget(int k)<T> List<Future<T>>invokeAll(Collection<? extends Callable<T>> tasks)<T> List<Future<T>>invokeAll(Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit)static <T> voidinvokeAndShutdown(ExecutorService pool, Collection<? extends Callable<T>> tasks)<T> TinvokeAny(Collection<? extends Callable<T>> tasks)<T> TinvokeAny(Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit)booleanisShutdown()booleanisTerminated()voidshutdown()static voidshutdownAsyncRDDPool()List<Runnable>shutdownNow()static voidshutdownShared()Future<?>submit(Runnable task)<T> Future<T>submit(Runnable task, T result)<T> Future<T>submit(Callable<T> task)
 
- 
- 
- 
Field Detail- 
triggerRemoteOPsPoolpublic static ExecutorService triggerRemoteOPsPool 
 
- 
 - 
Constructor Detail- 
CommonThreadPoolpublic CommonThreadPool(ExecutorService pool) 
 
- 
 - 
Method Detail- 
getpublic static ExecutorService get(int k) 
 - 
invokeAndShutdownpublic static <T> void invokeAndShutdown(ExecutorService pool, Collection<? extends Callable<T>> tasks) 
 - 
shutdownSharedpublic static void shutdownShared() 
 - 
shutdownAsyncRDDPoolpublic static void shutdownAsyncRDDPool() 
 - 
shutdownpublic void shutdown() - Specified by:
- shutdownin interface- ExecutorService
 
 - 
shutdownNowpublic List<Runnable> shutdownNow() - Specified by:
- shutdownNowin interface- ExecutorService
 
 - 
invokeAllpublic <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks) throws InterruptedException - Specified by:
- invokeAllin interface- ExecutorService
- Throws:
- InterruptedException
 
 - 
invokeAllpublic <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) throws InterruptedException - Specified by:
- invokeAllin interface- ExecutorService
- Throws:
- InterruptedException
 
 - 
submitpublic <T> Future<T> submit(Callable<T> task) - Specified by:
- submitin interface- ExecutorService
 
 - 
submitpublic <T> Future<T> submit(Runnable task, T result) - Specified by:
- submitin interface- ExecutorService
 
 - 
submitpublic Future<?> submit(Runnable task) - Specified by:
- submitin interface- ExecutorService
 
 - 
isShutdownpublic boolean isShutdown() - Specified by:
- isShutdownin interface- ExecutorService
 
 - 
isTerminatedpublic boolean isTerminated() - Specified by:
- isTerminatedin interface- ExecutorService
 
 - 
awaitTerminationpublic boolean awaitTermination(long timeout, TimeUnit unit) throws InterruptedException- Specified by:
- awaitTerminationin interface- ExecutorService
- Throws:
- InterruptedException
 
 - 
invokeAnypublic <T> T invokeAny(Collection<? extends Callable<T>> tasks) throws InterruptedException, ExecutionException - Specified by:
- invokeAnyin interface- ExecutorService
- Throws:
- InterruptedException
- ExecutionException
 
 - 
invokeAnypublic <T> T invokeAny(Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) throws InterruptedException, ExecutionException, TimeoutException - Specified by:
- invokeAnyin interface- ExecutorService
- Throws:
- InterruptedException
- ExecutionException
- TimeoutException
 
 
- 
 
-