Beatmup::Context::Impl Class Reference

Context class implementation (pimpl) More...

Classes
class	ThreadPoolEventListener
	Thread pool event listener. More...

Public Member Functions
	Impl (const PoolIndex numThreadPools)
	~Impl ()
float	performTask (PoolIndex pool, AbstractTask &task)
void	repeatTask (PoolIndex pool, AbstractTask &task, bool abortCurrent)
Job	submitTask (const PoolIndex pool, AbstractTask &task)
Job	submitPersistentTask (const PoolIndex pool, AbstractTask &task)
void	waitForJob (const PoolIndex pool, Job job)
bool	abortJob (const PoolIndex pool, Job job)
void	wait (const PoolIndex pool)
bool	busy (const PoolIndex pool)
void	check (const PoolIndex pool)
const ThreadIndex	maxAllowedWorkerCount (const PoolIndex pool) const
void	limitWorkerCount (const PoolIndex pool, ThreadIndex maxValue)
bool	isGpuQueried () const
bool	isGpuReady () const
bool	isManagingThread () const

Public Attributes
Context::EventListener *	eventListener
	an event listener More...

Private Attributes
ThreadIndex	optimalThreadCount
	optimal default number of worker threads per task in each pool More...
ThreadPool **	threadPools
	thread pools of task workers More...
PoolIndex	numThreadPools
ThreadPoolEventListener	threadPoolEventListener

Detailed Description

Context class implementation (pimpl)

Definition at line 43 of file context.cpp.

Constructor & Destructor Documentation

Impl()

Beatmup::Context::Impl::Impl ( const PoolIndex  numThreadPools )

inline

Definition at line 118 of file context.cpp.

                                         :
        optimalThreadCount(std::max<ThreadIndex>(1, ThreadPool::hardwareConcurrency() / numThreadPools)),
        numThreadPools(numThreadPools),
        threadPoolEventListener(*this),
        eventListener(nullptr)
    {
        threadPools = new ThreadPool*[numThreadPools];
        for (PoolIndex pool = 0; pool < numThreadPools; pool++)
            threadPools[pool] = new ThreadPool(pool, optimalThreadCount, threadPoolEventListener);
    }

~Impl()

Beatmup::Context::Impl::~Impl ( )

inline

Definition at line 130 of file context.cpp.

            {
        for (PoolIndex i = 0; i < numThreadPools; i++)
            delete threadPools[i];
        delete[] threadPools;
    }

Member Function Documentation

performTask()

float Beatmup::Context::Impl::performTask ( PoolIndex  pool, AbstractTask &  task  )

inline

Definition at line 137 of file context.cpp.

                                                          {
        BEATMUP_ASSERT_DEBUG(pool < numThreadPools);
        auto startTime = std::chrono::high_resolution_clock::now();
        Job job = threadPools[pool]->submitTask(task, ThreadPool::TaskExecutionMode::NORMAL);
        threadPools[pool]->waitForJob(job);
        auto endTime = std::chrono::high_resolution_clock::now();
        threadPools[pool]->check();
        return std::chrono::duration<float, std::milli>(endTime - startTime).count();
    }

repeatTask()

void Beatmup::Context::Impl::repeatTask ( PoolIndex  pool, AbstractTask &  task, bool  abortCurrent  )

inline

Definition at line 148 of file context.cpp.

                                                                           {
        BEATMUP_ASSERT_DEBUG(pool < numThreadPools);
        threadPools[pool]->repeatTask(task, abortCurrent);
    }

submitTask()

Job Beatmup::Context::Impl::submitTask ( const PoolIndex  pool, AbstractTask &  task  )

inline

Definition at line 154 of file context.cpp.

                                                             {
        BEATMUP_ASSERT_DEBUG(pool < numThreadPools);
        return threadPools[pool]->submitTask(task, ThreadPool::TaskExecutionMode::NORMAL);
    }

submitPersistentTask()

Job Beatmup::Context::Impl::submitPersistentTask ( const PoolIndex  pool, AbstractTask &  task  )

inline

Definition at line 160 of file context.cpp.

                                                                       {
        BEATMUP_ASSERT_DEBUG(pool < numThreadPools);
        return threadPools[pool]->submitTask(task, ThreadPool::TaskExecutionMode::PERSISTENT);
    }

waitForJob()

void Beatmup::Context::Impl::waitForJob ( const PoolIndex  pool, Job  job  )

inline

Definition at line 166 of file context.cpp.

                                                   {
        BEATMUP_ASSERT_DEBUG(pool < numThreadPools);
        threadPools[pool]->waitForJob(job);
    }

abortJob()

bool Beatmup::Context::Impl::abortJob ( const PoolIndex  pool, Job  job  )

inline

Definition at line 172 of file context.cpp.

                                                 {
        BEATMUP_ASSERT_DEBUG(pool < numThreadPools);
        return threadPools[pool]->abortJob(job);
    }

wait()

void Beatmup::Context::Impl::wait ( const PoolIndex  pool )

inline

Definition at line 178 of file context.cpp.

                                    {
        BEATMUP_ASSERT_DEBUG(pool < numThreadPools);
        threadPools[pool]->wait();
    }

busy()

bool Beatmup::Context::Impl::busy ( const PoolIndex  pool )

inline

Definition at line 184 of file context.cpp.

                                    {
        BEATMUP_ASSERT_DEBUG(pool < numThreadPools);
        return threadPools[pool]->busy();
    }

check()

void Beatmup::Context::Impl::check ( const PoolIndex  pool )

inline

Definition at line 190 of file context.cpp.

                                     {
        threadPools[pool]->check();
    }

maxAllowedWorkerCount()

const ThreadIndex Beatmup::Context::Impl::maxAllowedWorkerCount ( const PoolIndex  pool ) const

inline

Definition at line 195 of file context.cpp.

                                                                        {
        BEATMUP_ASSERT_DEBUG(pool < numThreadPools);
        return threadPools[pool]->getThreadCount();
    }

limitWorkerCount()

void Beatmup::Context::Impl::limitWorkerCount ( const PoolIndex  pool, ThreadIndex  maxValue  )

inline

Definition at line 201 of file context.cpp.

                                                                      {
        BEATMUP_ASSERT_DEBUG(pool < numThreadPools);
        threadPools[pool]->resize(maxValue);
    }

isGpuQueried()

bool Beatmup::Context::Impl::isGpuQueried ( ) const

inline

Definition at line 207 of file context.cpp.

                                     {
        return threadPools[0]->isGpuQueried();
    }

isGpuReady()

bool Beatmup::Context::Impl::isGpuReady ( ) const

inline

Definition at line 212 of file context.cpp.

                                   {
        return threadPools[0]->isGpuReady();
    }

isManagingThread()

bool Beatmup::Context::Impl::isManagingThread ( ) const

inline

Definition at line 217 of file context.cpp.

                                         {
        for (PoolIndex pool = 0; pool < numThreadPools; ++pool)
            if (threadPools[pool]->isManagingThread())
                return true;
        return false;
    }

Member Data Documentation

optimalThreadCount

ThreadIndex Beatmup::Context::Impl::optimalThreadCount

private

optimal default number of worker threads per task in each pool

Definition at line 108 of file context.cpp.

threadPools

ThreadPool** Beatmup::Context::Impl::threadPools

private

thread pools of task workers

Definition at line 110 of file context.cpp.

numThreadPools

PoolIndex Beatmup::Context::Impl::numThreadPools

private

Definition at line 111 of file context.cpp.

threadPoolEventListener

ThreadPoolEventListener Beatmup::Context::Impl::threadPoolEventListener

private

Definition at line 112 of file context.cpp.

eventListener

Context::EventListener* Beatmup::Context::Impl::eventListener

an event listener

Definition at line 116 of file context.cpp.

---

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

• core/context.cpp