prio_dedicated_threads/one_per_prio/pub.cpp File Reference

Functions for creating and binding of the dispatcher with dedicated threads per priority. More...

#include <so_5/disp/prio_dedicated_threads/one_per_prio/h/pub.hpp>
#include <so_5/disp/reuse/work_thread/h/work_thread.hpp>
#include <so_5/disp/reuse/h/disp_binder_helpers.hpp>
#include <so_5/disp/reuse/h/data_source_prefix_helpers.hpp>
#include <so_5/disp/reuse/h/proxy_dispatcher_template.hpp>
#include <so_5/rt/stats/h/repository.hpp>
#include <so_5/rt/stats/h/messages.hpp>
#include <so_5/rt/stats/h/std_names.hpp>
#include <so_5/rt/h/send_functions.hpp>
#include <so_5/details/h/invoke_noexcept_code.hpp>
#include <so_5/h/stdcpp.hpp>
#include <algorithm>

Classes
class	so_5::disp::prio_dedicated_threads::one_per_prio::impl::actual_disp_iface_t
	An actual interface of active group dispatcher. More...
class	so_5::disp::prio_dedicated_threads::one_per_prio::impl::dispatcher_template_t< Work_Thread >
	An actual implementation of dispatcher with dedicated thread for every priority in form of a template class. More...
class	so_5::disp::prio_dedicated_threads::one_per_prio::impl::dispatcher_template_t< Work_Thread >::disp_data_source_t
	Data source for run-time monitoring of whole dispatcher. More...
class	so_5::disp::prio_dedicated_threads::one_per_prio::impl::proxy_dispatcher_t
	A proxy dispatcher which creates actual dispatcher at start. More...
class	so_5::disp::prio_dedicated_threads::one_per_prio::impl::binding_actions_mixin_t
	Implementation of binding actions to be reused in various binder implementation. More...
class	so_5::disp::prio_dedicated_threads::one_per_prio::impl::real_private_dispatcher_t
	A real implementation of private_dispatcher interface. More...

Namespaces
	so_5
	Public part of message limit implementation.
	so_5::disp
	Event dispatchers.
	so_5::disp::prio_dedicated_threads
	Dispatchers with dedicated threads for every priority.
	so_5::disp::prio_dedicated_threads::one_per_prio
	Dispatcher which creates exactly one thread per priority.
	so_5::disp::prio_dedicated_threads::one_per_prio::impl
	Implementation details for dispatcher with one thread per priority.
	so_5::disp::prio_dedicated_threads::one_per_prio::impl::anonymous_namespace{pub.cpp}

Typedefs
using	so_5::disp::prio_dedicated_threads::one_per_prio::impl::proxy_dispatcher_base_t = so_5::disp::reuse::proxy_dispatcher_template_t< actual_disp_iface_t, disp_params_t >
using	so_5::disp::prio_dedicated_threads::one_per_prio::impl::disp_binder_t = so_5::disp::reuse::binder_for_public_disp_template_t< proxy_dispatcher_t, binding_actions_mixin_t >
	Binder for public dispatcher. More...
using	so_5::disp::prio_dedicated_threads::one_per_prio::impl::private_dispatcher_binder_t = so_5::disp::reuse::binder_for_private_disp_template_t< private_dispatcher_handle_t, proxy_dispatcher_t, binding_actions_mixin_t >
	A binder for the private strictly_ordered dispatcher. More...

Functions
void	so_5::disp::prio_dedicated_threads::one_per_prio::impl::anonymous_namespace{pub.cpp}::send_thread_activity_stats (const so_5::mbox_t &, const stats::prefix_t &, so_5::disp::reuse::work_thread::work_thread_no_activity_tracking_t &)
void	so_5::disp::prio_dedicated_threads::one_per_prio::impl::anonymous_namespace{pub.cpp}::send_thread_activity_stats (const so_5::mbox_t &mbox, const stats::prefix_t &prefix, so_5::disp::reuse::work_thread::work_thread_with_activity_tracking_t &wt)
SO_5_FUNC dispatcher_unique_ptr_t	so_5::disp::prio_dedicated_threads::one_per_prio::create_disp ( disp_params_t params)
	Create an instance of dispatcher to be used as named dispatcher. More...
SO_5_FUNC private_dispatcher_handle_t	so_5::disp::prio_dedicated_threads::one_per_prio::create_private_disp ( environment_t &env, const std::string &data_sources_name_base, disp_params_t params)
	Create a private one_per_prio dispatcher. More...
SO_5_FUNC disp_binder_unique_ptr_t	so_5::disp::prio_dedicated_threads::one_per_prio::create_disp_binder ( const std::string &disp_name)
	Create a dispatcher binder object. More...

Detailed Description

Functions for creating and binding of the dispatcher with dedicated threads per priority.

Since

v.5.5.8