so_5::disp::adv_thread_pool Namespace Reference

Advanced thread pool dispatcher. More...

Namespaces
namespace	anonymous_namespace{pub.cpp}
namespace	impl
	Internal implementation details of advanced thread pool dispatcher.

Classes
class	bind_params_t
	Parameters for binding agents to adv_thread_pool dispatcher. More...
class	disp_params_t
	Alias for namespace with traits of event queue. More...
class	dispatcher_handle_t
	A handle for adv_thread_pool dispatcher. More...

Enumerations
enum class	fifo_t { cooperation , individual }
	Type of FIFO mechanism for agent's demands. More...

Functions
SO_5_FUNC dispatcher_handle_t	make_dispatcher ( environment_t &env, const std::string_view data_sources_name_base, disp_params_t disp_params)
	Create an instance of adv_thread_pool dispatcher.
dispatcher_handle_t	make_dispatcher (environment_t &env, const std::string_view data_sources_name_base, std::size_t thread_count)
	Create an instance of adv_thread_pool dispatcher.
dispatcher_handle_t	make_dispatcher (environment_t &env, std::size_t thread_count)
	Create an instance of adv_thread_pool dispatcher.
dispatcher_handle_t	make_dispatcher (environment_t &env)
	Create an instance of adv_thread_pool dispatcher with the default count of work threads.

Detailed Description

Advanced thread pool dispatcher.

Enumeration Type Documentation

fifo_t

enum class so_5::disp::adv_thread_pool::fifo_t

strong

Type of FIFO mechanism for agent's demands.

Since

v.5.4.0

Enumerator
cooperation	A FIFO for demands for all agents from the same cooperation. It means that agents from the same cooperation for which this FIFO mechanism is used will be worked on the same thread. If the same disp_binder with fifo_t::cooperation is used for several cooperations then each coop will have a separate event queue (thus agents from different coops may work on different worker threads).
individual	A FIFO for demands only for one agent. It means that FIFO is only supported for the concrete agent. If several agents from a cooperation have this FIFO type they will process demands independently and on different threads.

Definition at line 158 of file adv_thread_pool/pub.hpp.

Function Documentation

make_dispatcher() [1/4]

SO_5_FUNC dispatcher_handle_t so_5::disp::adv_thread_pool::make_dispatcher	(	environment_t &	env,
		const std::string_view	data_sources_name_base,
		disp_params_t	disp_params )

Create an instance of adv_thread_pool dispatcher.

Usage sample

using namespace so_5::disp::adv_thread_pool;
auto disp = make_dispatcher(
  env,
  "db_workers_pool",
  disp_params_t{}
    .thread_count( 16 )
    .tune_queue_params( []( queue_traits::queue_params_t & params ) {
        params.lock_factory( queue_traits::simple_lock_factory() );
      } ) );
auto coop = env.make_coop(
  // The main dispatcher for that coop will be
  // this instance of adv_thread_pool dispatcher.
  disp.binder() );

Since

v.5.6.0

Parameters

env	SObjectizer Environment to work in.
data_sources_name_base	Value for creating names of data sources for run-time monitoring.
disp_params	Parameters for the dispatcher.

Definition at line 243 of file adv_thread_pool/pub.cpp.

make_dispatcher() [2/4]

dispatcher_handle_t so_5::disp::adv_thread_pool::make_dispatcher ( environment_t & env )

inline

Create an instance of adv_thread_pool dispatcher with the default count of work threads.

Count of work threads will be detected by default_thread_pool_size() function.

Usage sample

auto disp = so_5::disp::adv_thread_pool::make_dispatcher( env );
 
auto coop = env.make_coop(
  // The main dispatcher for that coop will be
  // this instance of adv_thread_pool dispatcher.
  disp.binder() );

Since

v.5.6.0

Parameters

env	SObjectizer Environment to work in.

Definition at line 501 of file adv_thread_pool/pub.hpp.

make_dispatcher() [3/4]

dispatcher_handle_t so_5::disp::adv_thread_pool::make_dispatcher ( environment_t & env, const std::string_view data_sources_name_base, std::size_t thread_count )

inline

Create an instance of adv_thread_pool dispatcher.

Usage sample

auto disp = so_5::disp::adv_thread_pool::make_dispatcher(
  env,
  "req_processors",
  16 );
auto coop = env.make_coop(
  // The main dispatcher for that coop will be
  // this instance of adv_thread_pool dispatcher.
  disp.binder() );

Since

v.5.6.0

Parameters

env	SObjectizer Environment to work in.
data_sources_name_base	Value for creating names of data sources for run-time monitoring.
thread_count	Count of working threads.

Definition at line 436 of file adv_thread_pool/pub.hpp.

make_dispatcher() [4/4]

dispatcher_handle_t so_5::disp::adv_thread_pool::make_dispatcher ( environment_t & env, std::size_t thread_count )

inline

Create an instance of adv_thread_pool dispatcher.

Usage sample

auto disp = so_5::disp::adv_thread_pool::make_dispatcher( env, 16 );
 
auto coop = env.make_coop(
  // The main dispatcher for that coop will be
  // this instance of adv_thread_pool dispatcher.
  disp.binder() );

Since

v.5.6.0

Parameters

env	SObjectizer Environment to work in.
thread_count	Count of working threads.

Definition at line 468 of file adv_thread_pool/pub.hpp.