public
interface
TaskExecutor
| org.apache.helix.messaging.handling.TaskExecutor |
 Known Indirect Subclasses
|
Summary
| Constants | |||||||||||
|---|---|---|---|---|---|---|---|---|---|---|---|
| int | DEFAULT_PARALLEL_TASKS | ||||||||||
| Public Methods | |||||||||||
|---|---|---|---|---|---|---|---|---|---|---|---|
cancel a message execution
| |||||||||||
cancel the timeout for the given task
| |||||||||||
finish a message execution
| |||||||||||
blocking on scheduling all tasks
| |||||||||||
register message handler factory this executor can handle
| |||||||||||
register message handler factory this executor can handle with specified
thread-pool size
| |||||||||||
schedule a message execution
| |||||||||||
shutdown executor
| |||||||||||
Constants
public static final int DEFAULT_PARALLEL_TASKS
Constant Value:
40
(0x00000028)
Public Methods
public abstract List<Future<HelixTaskResult>> invokeAllTasks (List<MessageTask> tasks, long timeout, TimeUnit unit)
blocking on scheduling all tasks
Throws
| InterruptedException |
|---|
public abstract void registerMessageHandlerFactory (String type, MessageHandlerFactory factory)
register message handler factory this executor can handle
public abstract void registerMessageHandlerFactory (String type, MessageHandlerFactory factory, int threadPoolSize)
register message handler factory this executor can handle with specified thread-pool size
public abstract void shutdown ()
shutdown executor