so_5::disp::nef_thread_pool Namespace Reference

Namespaces
namespace	anonymous_namespace{pub.cpp}
namespace	impl

Classes
class	bind_params_t
	Parameters for binding agents to nef_thread_pool dispatcher. More...
class	disp_params_t
	Alias for namespace with traits of event queue. More...
class	dispatcher_handle_t
	A handle for nef_thread_pool dispatcher. 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 nef_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 nef_thread_pool dispatcher.
dispatcher_handle_t	make_dispatcher (environment_t &env, std::size_t thread_count)
	Create an instance of nef_thread_pool dispatcher.
dispatcher_handle_t	make_dispatcher (environment_t &env)
	Create an instance of nef_thread_pool dispatcher with the default count of working threads.

Function Documentation

make_dispatcher() [1/4]

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

nodiscard

Create an instance nef_thread_pool dispatcher.

Usage sample

using namespace so_5::disp::nef_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 nef_thread_pool dispatcher.
  disp.binder() );

Since

v.5.8.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 423 of file nef_thread_pool/pub.cpp.

make_dispatcher() [2/4]

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

inlinenodiscard

Create an instance of nef_thread_pool dispatcher with the default count of working threads.

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

Usage sample

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

Since

v.5.8.0

Parameters

env	SObjectizer Environment to work in.

Definition at line 467 of file nef_thread_pool/pub.hpp.

make_dispatcher() [3/4]

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

inlinenodiscard

Create an instance of nef_thread_pool dispatcher.

Usage sample

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

Since

v.5.8.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 402 of file nef_thread_pool/pub.hpp.

make_dispatcher() [4/4]

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

inlinenodiscard

Create an instance of nef_thread_pool dispatcher.

Usage sample

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

Since

v.5.8.0

Parameters

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

Definition at line 434 of file nef_thread_pool/pub.hpp.