SObjectizer
5.7
|
Functions for creating and binding of the dispatcher with dedicated threads per priority. More...
#include <so_5/disp/prio_dedicated_threads/one_per_prio/pub.hpp>
#include <so_5/disp/reuse/work_thread/work_thread.hpp>
#include <so_5/disp/reuse/actual_work_thread_factory_to_use.hpp>
#include <so_5/disp/reuse/data_source_prefix_helpers.hpp>
#include <so_5/disp/reuse/make_actual_dispatcher.hpp>
#include <so_5/stats/repository.hpp>
#include <so_5/stats/messages.hpp>
#include <so_5/stats/std_names.hpp>
#include <so_5/send_functions.hpp>
#include <so_5/details/invoke_noexcept_code.hpp>
#include <algorithm>
Classes | |
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::dispatcher_handle_maker_t |
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} | |
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_handle_t | so_5::disp::prio_dedicated_threads::one_per_prio::make_dispatcher ( environment_t &env, const std::string_view data_sources_name_base, disp_params_t params) |
Create an instance of one_per_prio dispatcher. More... | |
Functions for creating and binding of the dispatcher with dedicated threads per priority.