WorkStealingThreadPool< CONTEXT > Class Template Reference

#include <WorkStealingThreadPool.h>

Public Member Functions
template<typename TaskT >
auto	executeAsync (TaskT &&task, int idx=-1) -> std::future< decltype(task(std::declval< CONTEXT >()))>
void	waitAll ()
	WorkStealingThreadPool (const bool workSteal, const std::vector< CONTEXT > &context)
	~WorkStealingThreadPool ()

Private Member Functions
void	run (size_t queueIndex, const CONTEXT &context)
void	workStealRun (size_t queueIndex, const CONTEXT &context)

Private Attributes
std::atomic< size_t >	myQueueIndex { 0 }
std::vector< TaskQueue< CONTEXT > >	myQueues
std::vector< std::thread >	myThreads
const size_t	myTryoutCount

Detailed Description

template<typename CONTEXT = int>
class WorkStealingThreadPool< CONTEXT >

Definition at line 30 of file WorkStealingThreadPool.h.

Constructor & Destructor Documentation

WorkStealingThreadPool()

template<typename CONTEXT = int>

WorkStealingThreadPool< CONTEXT >::WorkStealingThreadPool ( const bool  workSteal, const std::vector< CONTEXT > &  context  )

inlineexplicit

Definition at line 33 of file WorkStealingThreadPool.h.

References WorkStealingThreadPool< CONTEXT >::myThreads, WorkStealingThreadPool< CONTEXT >::run(), and WorkStealingThreadPool< CONTEXT >::workStealRun().

~WorkStealingThreadPool()

template<typename CONTEXT = int>

WorkStealingThreadPool< CONTEXT >::~WorkStealingThreadPool ( )

inline

Definition at line 46 of file WorkStealingThreadPool.h.

References WorkStealingThreadPool< CONTEXT >::myQueues, and WorkStealingThreadPool< CONTEXT >::myThreads.

Member Function Documentation

executeAsync()

template<typename CONTEXT = int>

template<typename TaskT >

auto WorkStealingThreadPool< CONTEXT >::executeAsync ( TaskT &&  task, int  idx = -1  ) -> std::future<decltype(task(std::declval<CONTEXT>()))>

inline

Definition at line 56 of file WorkStealingThreadPool.h.

References WorkStealingThreadPool< CONTEXT >::myQueueIndex, WorkStealingThreadPool< CONTEXT >::myQueues, and WorkStealingThreadPool< CONTEXT >::myTryoutCount.

Referenced by WorkStealingThreadPool< CONTEXT >::waitAll().

Here is the caller graph for this function:

run()

template<typename CONTEXT = int>

void WorkStealingThreadPool< CONTEXT >::run ( size_t  queueIndex, const CONTEXT &  context  )

inlineprivate

Definition at line 86 of file WorkStealingThreadPool.h.

References WorkStealingThreadPool< CONTEXT >::myQueues.

Referenced by WorkStealingThreadPool< CONTEXT >::WorkStealingThreadPool().

Here is the caller graph for this function:

waitAll()

template<typename CONTEXT = int>

void WorkStealingThreadPool< CONTEXT >::waitAll ( )

inline

Definition at line 75 of file WorkStealingThreadPool.h.

References WorkStealingThreadPool< CONTEXT >::executeAsync(), and WorkStealingThreadPool< CONTEXT >::myQueues.

workStealRun()

template<typename CONTEXT = int>

void WorkStealingThreadPool< CONTEXT >::workStealRun ( size_t  queueIndex, const CONTEXT &  context  )

inlineprivate

Definition at line 95 of file WorkStealingThreadPool.h.

References WorkStealingThreadPool< CONTEXT >::myQueues, and WorkStealingThreadPool< CONTEXT >::myTryoutCount.

Referenced by WorkStealingThreadPool< CONTEXT >::WorkStealingThreadPool().

Here is the caller graph for this function:

Field Documentation

myQueueIndex

template<typename CONTEXT = int>

std::atomic<size_t> WorkStealingThreadPool< CONTEXT >::myQueueIndex { 0 }

private

Definition at line 112 of file WorkStealingThreadPool.h.

Referenced by WorkStealingThreadPool< CONTEXT >::executeAsync().

myQueues

template<typename CONTEXT = int>

std::vector<TaskQueue<CONTEXT> > WorkStealingThreadPool< CONTEXT >::myQueues

private

Definition at line 111 of file WorkStealingThreadPool.h.

Referenced by WorkStealingThreadPool< CONTEXT >::executeAsync(), WorkStealingThreadPool< CONTEXT >::run(), WorkStealingThreadPool< CONTEXT >::waitAll(), WorkStealingThreadPool< CONTEXT >::workStealRun(), and WorkStealingThreadPool< CONTEXT >::~WorkStealingThreadPool().

myThreads

template<typename CONTEXT = int>

std::vector<std::thread> WorkStealingThreadPool< CONTEXT >::myThreads

private

Definition at line 114 of file WorkStealingThreadPool.h.

Referenced by WorkStealingThreadPool< CONTEXT >::WorkStealingThreadPool(), and WorkStealingThreadPool< CONTEXT >::~WorkStealingThreadPool().

myTryoutCount

template<typename CONTEXT = int>

const size_t WorkStealingThreadPool< CONTEXT >::myTryoutCount

private

Definition at line 113 of file WorkStealingThreadPool.h.

Referenced by WorkStealingThreadPool< CONTEXT >::executeAsync(), and WorkStealingThreadPool< CONTEXT >::workStealRun().

---

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

• WorkStealingThreadPool.h