org.apache.ignite.internal.processors.hadoop.taskexecutor

Class HadoopExecutorService

java.lang.Object

org.apache.ignite.internal.processors.hadoop.taskexecutor.HadoopExecutorService

public class HadoopExecutorService
extends Object

Executor service without thread pooling.

Constructor Summary

Constructors

Constructor and Description
HadoopExecutorService(IgniteLogger log, String igniteInstanceName, int maxTasks, int maxQueue)

Method Summary

Modifier and Type	Method and Description
int	active()
boolean	isShutdown()
boolean	shutdown(long awaitTimeMillis) Shuts down this executor service.
void	submit(Callable<?> task) Submit task.

Methods inherited from class java.lang.Object

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

Constructor Detail

HadoopExecutorService

public HadoopExecutorService(IgniteLogger log,
                             String igniteInstanceName,
                             int maxTasks,
                             int maxQueue)

Parameters:

log - Logger.

igniteInstanceName - Ignite instance name.

maxTasks - Max number of tasks.

maxQueue - Max queue length.

Method Detail

active

public int active()

Returns:

Number of active workers.

submit

public void submit(Callable<?> task)

Submit task.

Parameters:

task - Task.

shutdown

public boolean shutdown(long awaitTimeMillis)

Shuts down this executor service.

Parameters:

awaitTimeMillis - Time in milliseconds to wait for tasks completion.

Returns:

true If all tasks completed.

isShutdown

public boolean isShutdown()

Returns:

true If method shutdown(long) was already called.