concurrent_task_loop.cpp File Reference

#include "flow/async/concurrent_task_loop.hpp"
#include "flow/error/error.hpp"

Go to the source code of this file.

Namespaces
namespace	flow
	Catch-all namespace for the Flow project: A collection of various production-quality modules written in modern C++17, originally by ygoldfel.
namespace	flow::async
	Flow module containing tools enabling multi-threaded event loops operating under the asynchronous-task proactor pattern, by providing a streamlined API around boost.asio event loops with added advanced task- and thread-scheduling features.

Functions
unsigned int	flow::async::optimal_worker_thread_count_per_pool (log::Logger *logger_ptr, bool est_hw_core_sharing_helps_algo)
	Assuming a planned thread pool will be receiving ~symmetrical load, and its UX-affecting (in particular, per-op latency-affecting) operations are largely between processor and RAM: Returns the # of threads to store in that pool for efficient performance. More...
void	flow::async::optimize_pinning_in_thread_pool (log::Logger *logger_ptr, const std::vector< util::Thread * > &threads_in_pool, bool est_hw_core_sharing_helps_algo, bool est_hw_core_pinning_helps_algo, bool hw_threads_is_grouping_collated, Error_code *err_code=nullptr)
	Assuming the same situation as documented for optimal_worker_thread_count_per_pool(), and that indeed the pool now contains that number of running threads: Attempts to optimize thread-core-pinning behavior in that pool for efficient performance. More...
void	flow::async::reset_thread_pinning (log::Logger *logger_ptr=nullptr, util::Thread *thread_else_ours=nullptr, Error_code *err_code=nullptr)
	Resets the processor-affinity of the given thread – or calling thread – to be managed as the OS deems best. More...
void	flow::async::reset_this_thread_pinning ()
	Resets processor-affinity of the calling thread; does not log; and throws on extremely unlikely system error. More...