Package ubic.gemma.cli.batch
Class BatchTaskExecutorService
- java.lang.Object
-
- ubic.gemma.core.util.concurrent.AbstractDelegatingExecutor
-
- ubic.gemma.core.util.concurrent.AbstractDelegatingExecutorService
-
- ubic.gemma.cli.batch.BatchTaskExecutorService
-
- All Implemented Interfaces:
Executor
,ExecutorService
,DelegatingExecutor
,DelegatingExecutorService
public class BatchTaskExecutorService extends AbstractDelegatingExecutorService
A task executor that automatically reports errors in batch tasks.
-
-
Constructor Summary
Constructors Constructor Description BatchTaskExecutorService(ExecutorService delegate, BatchTaskProgressReporter progressReporter)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description int
getRemainingTasks()
Obtain the number of completed batch tasks.protected Runnable
wrap(Runnable runnable)
protected <T> Callable<T>
wrap(Callable<T> callable)
-
Methods inherited from class ubic.gemma.core.util.concurrent.AbstractDelegatingExecutorService
awaitTermination, getDelegate, invokeAll, invokeAll, invokeAny, invokeAny, isShutdown, isTerminated, shutdown, shutdownNow, submit, submit, submit
-
Methods inherited from class ubic.gemma.core.util.concurrent.AbstractDelegatingExecutor
execute
-
-
-
-
Constructor Detail
-
BatchTaskExecutorService
public BatchTaskExecutorService(ExecutorService delegate, BatchTaskProgressReporter progressReporter)
-
-
Method Detail
-
wrap
protected Runnable wrap(Runnable runnable)
- Specified by:
wrap
in classAbstractDelegatingExecutor
-
wrap
protected <T> Callable<T> wrap(Callable<T> callable)
- Specified by:
wrap
in classAbstractDelegatingExecutorService
-
getRemainingTasks
public int getRemainingTasks()
Obtain the number of completed batch tasks.
-
-