public class

HelixTaskExecutor

extends Object
implements MessageListener TaskExecutor
java.lang.Object
   ↳ org.apache.helix.messaging.handling.HelixTaskExecutor

Summary

Constants
int DEFAULT_PARALLEL_TASKS
String MAX_THREADS
[Expand]
Inherited Constants
From interface org.apache.helix.messaging.handling.TaskExecutor
Fields
protected final Map<String, MessageTaskInfo> _taskMap
Public Constructors
HelixTaskExecutor()
Public Methods
boolean cancelTask(MessageTask task)
cancel a message execution
boolean cancelTimeoutTask(MessageTask task)
cancel the timeout for the given task
MessageHandler createMessageHandler(Message message, NotificationContext changeContext)
void finishTask(MessageTask task)
finish a message execution
ParticipantMonitor getParticipantMonitor()
List<Future<HelixTaskResult>> invokeAllTasks(List<MessageTask> tasks, long timeout, TimeUnit unit)
blocking on scheduling all tasks
void onMessage(String instanceName, List<Message> messages, NotificationContext changeContext)
Invoked when message changes
void registerMessageHandlerFactory(String type, MessageHandlerFactory factory)
register message handler factory this executor can handle
void registerMessageHandlerFactory(String type, MessageHandlerFactory factory, int threadpoolSize)
register message handler factory this executor can handle with specified thread-pool size
boolean scheduleTask(MessageTask task)
schedule a message execution
void shutdown()
shutdown executor
[Expand]
Inherited Methods
From class java.lang.Object
From interface org.apache.helix.MessageListener
From interface org.apache.helix.messaging.handling.TaskExecutor

Constants

public static final int DEFAULT_PARALLEL_TASKS

Constant Value: 40 (0x00000028)

public static final String MAX_THREADS

Constant Value: "maxThreads"

Fields

protected final Map<String, MessageTaskInfo> _taskMap

Public Constructors

public HelixTaskExecutor ()

Public Methods

public boolean cancelTask (MessageTask task)

cancel a message execution

public boolean cancelTimeoutTask (MessageTask task)

cancel the timeout for the given task

public MessageHandler createMessageHandler (Message message, NotificationContext changeContext)

public void finishTask (MessageTask task)

finish a message execution

public ParticipantMonitor getParticipantMonitor ()

public List<Future<HelixTaskResult>> invokeAllTasks (List<MessageTask> tasks, long timeout, TimeUnit unit)

blocking on scheduling all tasks

Throws
InterruptedException

public void onMessage (String instanceName, List<Message> messages, NotificationContext changeContext)

Invoked when message changes

public void registerMessageHandlerFactory (String type, MessageHandlerFactory factory)

register message handler factory this executor can handle

public void registerMessageHandlerFactory (String type, MessageHandlerFactory factory, int threadpoolSize)

register message handler factory this executor can handle with specified thread-pool size

public boolean scheduleTask (MessageTask task)

schedule a message execution

public void shutdown ()

shutdown executor