#include <thread_utils.hpp>

Public Member Functions
	named_thread_pool (std::string name_prefix, size_t num_threads)

	~named_thread_pool ()

boost::asio::io_context &	get_executor ()

void	stop ()

Detailed Description

Wrapper class for boost asio thread pool and io_context run. Also names threads so that tools like htop can see thread name.

Definition at line 16 of file thread_utils.hpp.

Constructor & Destructor Documentation

◆ named_thread_pool()

sysio::chain::named_thread_pool::named_thread_pool	(	std::string	name_prefix,
		size_t	num_threads )

Definition at line 10 of file thread_utils.cpp.

: _thread_pool( num_threads )
, _ioc( num_threads )
{
   _ioc_work.emplace( boost::asio::make_work_guard( _ioc ) );
   for( size_t i = 0; i < num_threads; ++i ) {
      boost::asio::post( _thread_pool, [&ioc = _ioc, name_prefix, i]() {
         std::string tn = name_prefix + "-" + std::to_string( i );
         fc::set_os_thread_name( tn );
         ioc.run();
      } );
   }
}

Here is the call graph for this function:

◆ ~named_thread_pool()

sysio::chain::named_thread_pool::~named_thread_pool ( )

Definition at line 24 of file thread_utils.cpp.

                                      {
   stop();
}

Here is the call graph for this function:

Member Function Documentation

◆ get_executor()

boost::asio::io_context & sysio::chain::named_thread_pool::get_executor ( )

inline

Definition at line 25 of file thread_utils.hpp.

25{ return _ioc; }

Here is the caller graph for this function:

◆ stop()

void sysio::chain::named_thread_pool::stop ( )

Definition at line 28 of file thread_utils.cpp.

                             {
   _ioc_work.reset();
   _ioc.stop();
   _thread_pool.join();
   _thread_pool.stop();
}