Distributed implementation of java.util.concurrent.ExecutorService. More...

#include <iexecutor_service.h>

Inheritance diagram for hazelcast::client::iexecutor_service:

Classes
class	executor_promise

Public Member Functions
template<typename HazelcastSerializable >
void	execute (const HazelcastSerializable &command)
	Executes the given command at some time in the future. More...

template<typename HazelcastSerializable >
void	execute (const HazelcastSerializable &command, const member_selector &member_selector)
	Executes a task on a randomly selected member. More...

template<typename HazelcastSerializable , typename K >
void	execute_on_key_owner (const HazelcastSerializable &command, const K &key)
	Executes a task on the owner of the specified key. More...

template<typename HazelcastSerializable >
void	execute_on_member (const HazelcastSerializable &command, const member &member)
	Executes a task on the specified member. More...

template<typename HazelcastSerializable >
void	execute_on_members (const HazelcastSerializable &command, const std::vector< member > &members)
	Executes a task on each of the specified members. More...

template<typename HazelcastSerializable >
void	execute_on_members (const HazelcastSerializable &command, const member_selector &member_selector)
	Executes a task on each of the selected members. More...

template<typename HazelcastSerializable >
void	execute_on_all_members (const HazelcastSerializable &command)
	Executes a task on all of the known cluster members. More...

template<typename HazelcastSerializable , typename T , typename K >
executor_promise< T >	submit_to_key_owner (const HazelcastSerializable &task, const K &key)
	Submits a task to the owner of the specified key and returns a executor_promise representing that task. More...

template<typename HazelcastSerializable , typename T >
executor_promise< T >	submit_to_member (const HazelcastSerializable &task, const member &member)
	Submits a task to the specified member and returns a executor_promise representing that task. More...

template<typename HazelcastSerializable , typename T >
std::unordered_map< member, executor_promise< T > >	submit_to_members (const HazelcastSerializable &task, const std::vector< member > &members)
	Submits a task to given members and returns map of Member-executor_promise pairs representing pending completion of the task on each member. More...

template<typename HazelcastSerializable , typename T >
std::unordered_map< member, executor_promise< T > >	submit_to_members (const HazelcastSerializable &task, const member_selector &member_selector)
	Submits a task to selected members and returns a map of Member-executor_promise pairs representing pending completion of the task on each member. More...

template<typename HazelcastSerializable , typename T >
std::unordered_map< member, executor_promise< T > >	submit_to_all_members (const HazelcastSerializable &task)
	Submits task to all cluster members and returns a map of Member-executor_promise pairs representing pending completion of the task on each member. More...

template<typename HazelcastSerializable , typename T >
executor_promise< T >	submit (const HazelcastSerializable &task)
	Submits a task for execution and returns a executor_promise representing that task. More...

template<typename HazelcastSerializable , typename T >
executor_promise< T >	submit (const HazelcastSerializable &task, const member_selector &member_selector)
	Submits a task to a randomly selected member and returns a executor_promise representing that task. More...

void	shutdown ()
	Initiates an orderly shutdown in which previously submitted tasks are executed, but no new tasks will be accepted. More...

boost::future< bool >	is_shutdown ()
	Returns. More...

boost::future< bool >	is_terminated ()
	Returns. More...

Static Public Attributes
static constexpr const char *	SERVICE_NAME = "hz:impl:executorService"

Friends
class	spi::ProxyManager

Detailed Description

Distributed implementation of java.util.concurrent.ExecutorService.

IExecutorService provides additional methods like executing tasks on a specific member, on a member who is owner of a specific key, executing a tasks on multiple members.

Member Function Documentation

◆ execute() [1/2]

template<typename HazelcastSerializable >

void hazelcast::client::iexecutor_service::execute ( const HazelcastSerializable & command )

inline

Executes the given command at some time in the future.

The command may execute in a new thread, in a pooled thread, or in the calling thread, at the discretion of the

Executor

implementation.

Parameters

command the runnable task

Exceptions

rejected_execution if this task cannot be accepted for execution

◆ execute() [2/2]

template<typename HazelcastSerializable >

void hazelcast::client::iexecutor_service::execute	(	const HazelcastSerializable &	command,
		const member_selector &	member_selector
	)

inline

Executes a task on a randomly selected member.

Parameters

command	the task that is executed on a randomly selected member
memberSelector	memberSelector

Exceptions

rejected_execution if no member is selected

◆ execute_on_all_members()

template<typename HazelcastSerializable >

void hazelcast::client::iexecutor_service::execute_on_all_members ( const HazelcastSerializable & command )

inline

Executes a task on all of the known cluster members.

Parameters

command a task executed on all of the known cluster members

◆ execute_on_key_owner()

template<typename HazelcastSerializable , typename K >

void hazelcast::client::iexecutor_service::execute_on_key_owner	(	const HazelcastSerializable &	command,
		const K &	key
	)

inline

Executes a task on the owner of the specified key.

Parameters

command	a task executed on the owner of the specified key
key	the specified key

◆ execute_on_member()

template<typename HazelcastSerializable >

void hazelcast::client::iexecutor_service::execute_on_member	(	const HazelcastSerializable &	command,
		const member &	member
	)

inline

Executes a task on the specified member.

Parameters

command	the task executed on the specified member
member	the specified member

◆ execute_on_members() [1/2]

template<typename HazelcastSerializable >

void hazelcast::client::iexecutor_service::execute_on_members	(	const HazelcastSerializable &	command,
		const std::vector< member > &	members
	)

inline

Executes a task on each of the specified members.

Parameters

command	the task executed on the specified members
members	the specified members

◆ execute_on_members() [2/2]

template<typename HazelcastSerializable >

void hazelcast::client::iexecutor_service::execute_on_members	(	const HazelcastSerializable &	command,
		const member_selector &	member_selector
	)

inline

Executes a task on each of the selected members.

Parameters

command	a task executed on each of the selected members
memberSelector	memberSelector

Exceptions

rejected_execution if no member is selected

◆ is_shutdown()

boost::future< bool > hazelcast::client::iexecutor_service::is_shutdown ( )

Returns.

true

if this executor has been shut down.

Returns: true
if this executor has been shut down

◆ is_terminated()

boost::future< bool > hazelcast::client::iexecutor_service::is_terminated ( )

Returns.

true

if all tasks have completed following shut down. Note that

isTerminated

is never

true

unless either

shutdown

.

Returns: true
if all tasks have completed following shut down

◆ shutdown()

void hazelcast::client::iexecutor_service::shutdown ( )

Initiates an orderly shutdown in which previously submitted tasks are executed, but no new tasks will be accepted.

Invocation has no additional effect if already shut down.

This method does not wait for previously submitted tasks to complete execution.

◆ submit() [1/2]

template<typename HazelcastSerializable , typename T >

executor_promise<T> hazelcast::client::iexecutor_service::submit ( const HazelcastSerializable & task )

inline

Submits a task for execution and returns a executor_promise representing that task.

The executor_promise's

executor_promise::get

method will return the given result upon successful completion.

Parameters

task	the task to submit
result	the result to return
<T>	the type of the result

Returns: a executor_promise representing pending completion of the task

Exceptions

rejected_execution	if the task cannot be scheduled for execution
null_pointer	if the task is null

◆ submit() [2/2]

template<typename HazelcastSerializable , typename T >

executor_promise<T> hazelcast::client::iexecutor_service::submit	(	const HazelcastSerializable &	task,
		const member_selector &	member_selector
	)

inline

Submits a task to a randomly selected member and returns a executor_promise representing that task.

Parameters

task	task submitted to a randomly selected member
memberSelector	memberSelector
<T>	the result type of callable

Returns: a executor_promise representing pending completion of the task

Exceptions

rejected_execution if no member is selected

◆ submit_to_all_members()

template<typename HazelcastSerializable , typename T >

std::unordered_map<member, executor_promise<T> > hazelcast::client::iexecutor_service::submit_to_all_members ( const HazelcastSerializable & task )

inline

Submits task to all cluster members and returns a map of Member-executor_promise pairs representing pending completion of the task on each member.

Parameters

task	the task submitted to all cluster members
<T>	the result type of callable

Returns: map of Member-executor_promise pairs representing pending completion of the task on each member

◆ submit_to_key_owner()

template<typename HazelcastSerializable , typename T , typename K >

executor_promise<T> hazelcast::client::iexecutor_service::submit_to_key_owner	(	const HazelcastSerializable &	task,
		const K &	key
	)

inline

Submits a task to the owner of the specified key and returns a executor_promise representing that task.

Parameters

task	task submitted to the owner of the specified key
key	the specified key
<T>	the result type of callable

Returns: a executor_promise representing pending completion of the task

◆ submit_to_member()

template<typename HazelcastSerializable , typename T >

executor_promise<T> hazelcast::client::iexecutor_service::submit_to_member	(	const HazelcastSerializable &	task,
		const member &	member
	)

inline

Submits a task to the specified member and returns a executor_promise representing that task.

Parameters

task	the task submitted to the specified member
member	the specified member
<T>	the result type of callable

Returns: a executor_promise representing pending completion of the task

◆ submit_to_members() [1/2]

template<typename HazelcastSerializable , typename T >

std::unordered_map<member, executor_promise<T> > hazelcast::client::iexecutor_service::submit_to_members	(	const HazelcastSerializable &	task,
		const std::vector< member > &	members
	)

inline

Submits a task to given members and returns map of Member-executor_promise pairs representing pending completion of the task on each member.

Parameters

task	the task submitted to given members
members	the given members
<T>	the result type of callable

Returns: map of Member-executor_promise pairs representing pending completion of the task on each member

◆ submit_to_members() [2/2]

template<typename HazelcastSerializable , typename T >

std::unordered_map<member, executor_promise<T> > hazelcast::client::iexecutor_service::submit_to_members	(	const HazelcastSerializable &	task,
		const member_selector &	member_selector
	)

inline

Submits a task to selected members and returns a map of Member-executor_promise pairs representing pending completion of the task on each member.

Parameters

task	the task submitted to selected members
memberSelector	memberSelector
<T>	the result type of callable

Returns: map of Member-executor_promise pairs representing pending completion of the task on each member

Exceptions

rejected_execution if no member is selected

The documentation for this class was generated from the following files:

hazelcast/include/hazelcast/client/iexecutor_service.h
hazelcast/src/hazelcast/client/client_impl.cpp

Classes

Public Member Functions

Static Public Attributes

Friends

Detailed Description

Member Function Documentation

◆ execute() [1/2]

◆ execute() [2/2]

◆ execute_on_all_members()

◆ execute_on_key_owner()

◆ execute_on_member()

◆ execute_on_members() [1/2]

◆ execute_on_members() [2/2]

◆ is_shutdown()

◆ is_terminated()

◆ shutdown()

◆ submit() [1/2]

◆ submit() [2/2]

◆ submit_to_all_members()

◆ submit_to_key_owner()

◆ submit_to_member()

◆ submit_to_members() [1/2]

◆ submit_to_members() [2/2]