XrdEc::ThreadPool Class Reference

#include <XrdEcThreadPool.hh>

Collaboration diagram for XrdEc::ThreadPool:

Classes
class	AnyJob
struct	seq_gen
struct	seq_gen< 0, Ns...>
struct	seq_gen< I, Ns...>
struct	sequence

Public Member Functions
	~ThreadPool ()
	Destructor. More...
template<typename FUNC , typename... ARGs>
std::future< typename std::result_of< FUNC(ARGs...)> ::type >	Execute (FUNC func, ARGs...args)
	Schedule a functional (together with its arguments) for execution. More...

Static Public Member Functions
static ThreadPool &	Instance ()
	Singleton access. More...

Private Member Functions
	ThreadPool ()
	Constructor. More...

Static Private Member Functions
template<typename FUNC , typename TUPL , int... INDICES>
static auto	tuple_call_impl (FUNC &func, TUPL &args, sequence< INDICES...>) -> decltype(func(std::move(std::get< INDICES >(args))...))
template<typename FUNC , typename... ARGs>
static auto	tuple_call (FUNC &func, std::tuple< ARGs...> &tup) -> decltype(tuple_call_impl(func, tup, typename seq_gen< sizeof...(ARGs)>::type

Private Attributes
XrdCl::JobManager	threadpool

Constructor & Destructor Documentation

XrdEc::ThreadPool::~ThreadPool ( )

inline

Destructor.

References XrdCl::JobManager::Finalize(), XrdCl::JobManager::Stop(), and threadpool.

XrdEc::ThreadPool::ThreadPool ( )

inlineprivate

Constructor.

References XrdCl::JobManager::Initialize(), XrdCl::JobManager::Start(), and threadpool.

Member Function Documentation

template<typename FUNC , typename... ARGs>

std::future<typename std::result_of<FUNC(ARGs...)>::type> XrdEc::ThreadPool::Execute ( FUNC  func, ARGs...  args  )

inline

Schedule a functional (together with its arguments) for execution.

References XrdEc::ThreadPool::AnyJob< FUNC, RET, ARGs >::GetFuture(), XrdCl::JobManager::QueueJob(), and threadpool.

Referenced by XrdEc::WrtBuff::Encode().

static ThreadPool& XrdEc::ThreadPool::Instance ( )

inlinestatic

Singleton access.

Referenced by XrdEc::WrtBuff::Encode(), and XrdEc::StrmWriter::EnqueueBuff().

template<typename FUNC , typename... ARGs>

static auto XrdEc::ThreadPool::tuple_call ( FUNC &  func, std::tuple< ARGs...> &  tup  ) -> decltype( tuple_call_impl( func, tup, typename seq_gen<sizeof...(ARGs)>::type

inlinestaticprivate

Referenced by XrdEc::ThreadPool::AnyJob< FUNC, RET, ARGs >::RunImpl().

template<typename FUNC , typename TUPL , int... INDICES>

static auto XrdEc::ThreadPool::tuple_call_impl ( FUNC &  func, TUPL &  args, sequence< INDICES...>    ) -> decltype( func( std::move( std::get<INDICES>( args ) )... ) )

inlinestaticprivate

Member Data Documentation

XrdCl::JobManager XrdEc::ThreadPool::threadpool

private

Referenced by Execute(), ThreadPool(), and ~ThreadPool().

---

The documentation for this class was generated from the following file:

• XrdEcThreadPool.hh