Executor

class Executor(service_name: str, name: str, context)[source]

Bases: Proxy[BlockingExecutor]

An object that executes submitted executable tasks.

execute_on_key_owner(key: Any, task: Any) → Future[Any][source]

Executes a task on the owner of the specified key.

Parameters:

  • key – The specified key.

  • task – A task executed on the owner of the specified key.

Returns:

The result of the task.

execute_on_member(member: MemberInfo, task: Any) → Future[Any][source]

Executes a task on the specified member.

Parameters:

  • member – The specified member.

  • task – The task executed on the specified member.

Returns:

The result of the task.

execute_on_members(members: Sequence[MemberInfo], task: Any) → Future[List[Any]][source]

Executes a task on each of the specified members.

Parameters:

  • members – The specified members.

  • task – The task executed on the specified members.

Returns:

The list of results of the tasks on each member.

execute_on_all_members(task: Any) → Future[List[Any]][source]

Executes a task on all the known cluster members.

Parameters:

task – The task executed on the all the members.

Returns:

The list of results of the tasks on each member.

is_shutdown() → Future[bool][source]

Determines whether this executor has been shutdown or not.

Returns:

True if the executor has been shutdown, False otherwise.

shutdown() → Future[None][source]

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

blocking() → BlockingExecutor[source]

Returns a version of this proxy with only blocking method calls.

class BlockingExecutor(wrapped: Executor)[source]

Bases: Executor

name
service_name
execute_on_key_owner(key: Any, task: Any) → Any[source]

Executes a task on the owner of the specified key.

Parameters:

  • key – The specified key.

  • task – A task executed on the owner of the specified key.

Returns:

The result of the task.

execute_on_member(member: MemberInfo, task: Any) → Any[source]

Executes a task on the specified member.

Parameters:

  • member – The specified member.

  • task – The task executed on the specified member.

Returns:

The result of the task.

execute_on_members(members: Sequence[MemberInfo], task: Any) → List[Any][source]

Executes a task on each of the specified members.

Parameters:

  • members – The specified members.

  • task – The task executed on the specified members.

Returns:

The list of results of the tasks on each member.

execute_on_all_members(task: Any) → List[Any][source]

Executes a task on all the known cluster members.

Parameters:

task – The task executed on the all the members.

Returns:

The list of results of the tasks on each member.

is_shutdown() → bool[source]

Determines whether this executor has been shutdown or not.

Returns:

True if the executor has been shutdown, False otherwise.

shutdown() → None[source]

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

blocking() → BlockingExecutor[source]

Returns a version of this proxy with only blocking method calls.

destroy() → bool[source]

Destroys this proxy.

Returns:

True if this proxy is destroyed successfully, False otherwise.