class ROOT::TProcessExecutor: public ROOT::TExecutor<ROOT::TProcessExecutor>, private TMPClient

 Execute func (with no arguments) nTimes in parallel.
 A vector containg executions' results is returned.
 Functions that take more than zero arguments can be executed (with
 fixed arguments) by wrapping them in a lambda or with std::bind.

This class is also known as (typedefs to this class)

TProcPool

Function Members (Methods)

public:

	~TProcessExecutor()
unsigned int	GetNWorkers() const
ROOT::TProcessExecutor&	operator=(const ROOT::TProcessExecutor&)
TList*	ProcTree(TTree& tree, TSelector& selector, ULong64_t nToProcess = 0)
TList*	ProcTree(const vector<string>& fileNames, TSelector& selector, const string& treeName = "", ULong64_t nToProcess = 0)
TList*	ProcTree(const string& fileName, TSelector& selector, const string& treeName = "", ULong64_t nToProcess = 0)
TList*	ProcTree(TFileCollection& files, TSelector& selector, const string& treeName = "", ULong64_t nToProcess = 0)
TList*	ProcTree(TChain& files, TSelector& selector, const string& treeName = "", ULong64_t nToProcess = 0)
void	SetNWorkers(unsigned int n)
ROOT::TExecutor<ROOT::TProcessExecutor>	ROOT::TExecutor<ROOT::TProcessExecutor>::TExecutor<ROOT::TProcessExecutor>()
ROOT::TExecutor<ROOT::TProcessExecutor>	ROOT::TExecutor<ROOT::TProcessExecutor>::TExecutor<ROOT::TProcessExecutor>(size_t)
ROOT::TExecutor<ROOT::TProcessExecutor>	ROOT::TExecutor<ROOT::TProcessExecutor>::TExecutor<ROOT::TProcessExecutor>(const ROOT::TExecutor<ROOT::TProcessExecutor>&)
ROOT::TExecutor<ROOT::TProcessExecutor>	ROOT::TExecutor<ROOT::TProcessExecutor>::TExecutor<ROOT::TProcessExecutor>(ROOT::TExecutor<ROOT::TProcessExecutor>&&)
ROOT::TProcessExecutor	TProcessExecutor(unsigned int nWorkers = 0)
ROOT::TProcessExecutor	TProcessExecutor(const ROOT::TProcessExecutor&)

private:

unsigned int	TMPClient::Broadcast(unsigned int code, unsigned int nMessages = 0)
unsigned int	TMPClient::Broadcast<std::vector<unsigned int, std::allocator<unsigned int> > >(unsigned int code, vector<unsigned int> obj, unsigned int nMessages = 0)
unsigned int	TMPClient::Broadcast<unsigned int>(unsigned int code, const vector<unsigned int>& args)
unsigned int	TMPClient::Broadcast<unsigned int>(unsigned int code, unsigned int obj, unsigned int nMessages = 0)
void	Collect<TObject >(vector<TObject>& reslist)
void	TMPClient::DeActivate(TSocket* s)
void	FixLists(vector<TObject*>& lists)
bool	TMPClient::Fork(TMPWorker& server)
bool	TMPClient::GetIsParent() const
TMonitor&	TMPClient::GetMonitor()
void	TMPClient::HandleMPCode(MPCodeBufPair& msg, TSocket* sender)
void	TMPClient::ReapWorkers()
void	TMPClient::Remove(TSocket* s)
void	ReplyToFuncResult(TSocket* s)
void	ReplyToIdle(TSocket* s)
void	Reset()

Data Members

private:

unsigned int	fNProcessed	number of arguments already passed to the workers
unsigned int	fNToProcess	total number of arguments to pass to the workers
ROOT::TProcessExecutor::ETask	fTaskType	the kind of task that is being executed, if any

Class Charts

Inheritance Chart:

ROOT::TExecutor

TMPClient

←

ROOT::TProcessExecutor

Function documentation

explicit TProcessExecutor(unsigned nWorkers = 0)

~TProcessExecutor()

it doesn't make sense for a TProcessExecutor to be copied

TProcessExecutor(const TProcessExecutor &)

TProcessExecutor & operator=(const ROOT::TProcessExecutor& )

template<class F> auto ProcTree(const std::vector<std::string>& fileNames, F procFunc, const std::string& treeName = "", ULong64_t nToProcess = 0)

 ProcTree
 these versions requires that procFunc returns a ptr to TObject or inheriting classes and takes a TTreeReader& (both enforced at compile-time)

template<class F> auto ProcTree(const std::string& fileName, F procFunc, const std::string& treeName = "", ULong64_t nToProcess = 0)

template<class F> auto ProcTree(TFileCollection& files, TSelector& selector, const string& treeName = "", ULong64_t nToProcess = 0)

template<class F> auto ProcTree(TChain& files, TSelector& selector, const string& treeName = "", ULong64_t nToProcess = 0)

template<class F> auto ProcTree(TTree& tree, TSelector& selector, ULong64_t nToProcess = 0)

 these versions require a TSelector

void SetNWorkers(unsigned int n)

{ TMPClient::SetNWorkers(n); }

unsigned GetNWorkers() const

{ return TMPClient::GetNWorkers(); }

void FixLists(vector<TObject*>& lists)

void Reset()

void ReplyToFuncResult(TSocket* s)

void ReplyToIdle(TSocket* s)