#include <XrdEcThreadPool.hh>

Collaboration diagram for XrdEc::ThreadPool:

Public Member Functions
	~ThreadPool ()
	Destructor.

template<typename FUNC , typename ... ARGs>
std::future< std::invoke_result_t< FUNC, ARGs... > >	Execute (FUNC func, ARGs... args)
	Schedule a functional (together with its arguments) for execution.

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

Detailed Description

Definition at line 38 of file XrdEcThreadPool.hh.

Constructor & Destructor Documentation

◆ ~ThreadPool()

XrdEc::ThreadPool::~ThreadPool ( )

inline

Destructor.

Definition at line 143 of file XrdEcThreadPool.hh.

      {
        threadpool.Stop();
        threadpool.Finalize();
      }

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

Here is the call graph for this function:

Member Function Documentation

◆ Execute()

template<typename FUNC , typename ... ARGs>

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

inline

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

Definition at line 163 of file XrdEcThreadPool.hh.

      {
        using RET = std::invoke_result_t<FUNC, ARGs...>;
        auto *job = new AnyJob<FUNC, RET, ARGs...>( func, std::move( args )... );
        std::future<RET> ftr = job->GetFuture();
        threadpool.QueueJob( job, nullptr );
        return ftr;
      }

References XrdCl::JobManager::QueueJob().

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

Here is the call graph for this function:

Here is the caller graph for this function:

◆ Instance()

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

inlinestatic

Singleton access.

Definition at line 152 of file XrdEcThreadPool.hh.

      {
        static ThreadPool instance;
        return instance;
      }