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:

AutoCloseable, Executor, ExecutorService, DelegatingExecutor, DelegatingExecutorService

public class BatchTaskExecutorService
extends AbstractDelegatingExecutorService
implements AutoCloseable

A task executor that automatically reports errors in batch tasks.

Constructor Summary

Constructors

Constructor	Description
BatchTaskExecutorService(ExecutorService delegate, BatchTaskProgressReporter progressReporter)

Method Summary

Modifier and Type	Method	Description
void	close()
BatchTaskProgressReporter	getProgressReporter()
int	getRemainingTasks()	Obtain the number of completed batch tasks.
void	shutdownAndAwaitTermination()
protected Runnable	wrap(Runnable runnable)
protected <T> Callable<T>	wrap(Callable<T> callable)

Methods inherited from class AbstractDelegatingExecutorService

awaitTermination, getDelegate, invokeAll, invokeAll, invokeAny, invokeAny, isShutdown, isTerminated, shutdown, shutdownNow, submit, submit, submit

Methods inherited from class AbstractDelegatingExecutor

execute

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface Executor

execute

Constructor Details

BatchTaskExecutorService

public BatchTaskExecutorService(ExecutorService delegate,
 BatchTaskProgressReporter progressReporter)

Method Details

getProgressReporter

public BatchTaskProgressReporter getProgressReporter()

wrap

protected Runnable wrap(Runnable runnable)

Specified by:

wrap in class AbstractDelegatingExecutor

wrap

protected <T> Callable<T> wrap(Callable<T> callable)

Specified by:

wrap in class AbstractDelegatingExecutorService

getRemainingTasks

public int getRemainingTasks()

Obtain the number of completed batch tasks.

shutdownAndAwaitTermination

public void shutdownAndAwaitTermination()
                                 throws InterruptedException

Throws:

InterruptedException

close

public void close()
           throws Exception

Specified by:

close in interface AutoCloseable

Throws:

Exception