Executor¶

class Executor(client, service_name, name)¶

An object that executes submitted executable tasks.

execute_on_key_owner(key, task)¶

Executes a task on the owner of the specified key.

Parameters:	key – (object), the specified key. task – (Task), a task executed on the owner of the specified key.
Returns:	(`Future`), future representing pending completion of the task.

execute_on_member(member, task)¶

Executes a task on the specified member.

Parameters:	member – (Member), the specified member. task – (Task), the task executed on the specified member.
Returns:	(`Future`), Future representing pending completion of the task.

execute_on_members(members, task)¶

Executes a task on each of the specified members.

Parameters:	members – (Collection), the specified members. task – (Task), the task executed on the specified members.
Returns:	(Map), `Future` tuples representing pending completion of the task on each member.

execute_on_all_members(task)¶

Executes a task on all of the known cluster members.

Parameters:	task – (Task), the task executed on the all of the members.
Returns:	(Map), `Future` tuples representing pending completion of the task on each member.

is_shutdown()¶

Determines whether this executor has been shut down or not.

Returns:	(bool), `true` if this executor has been shut down.

shutdown()¶: Initiates a shutdown process which works orderly. Tasks that were submitted before shutdown are executed but new task will not be accepted.