Beatmup::Context::Impl::ThreadPoolEventListener Class Reference

Thread pool event listener. More...

Inheritance diagram for Beatmup::Context::Impl::ThreadPoolEventListener:

Public Member Functions
	ThreadPoolEventListener (const Context::Impl &ctx)
void	threadCreated (PoolIndex pool)
	Callback function called when a new worker thread is created. More...
void	threadTerminating (PoolIndex pool)
	Callback function called when a worker thread is terminating. More...
bool	taskDone (PoolIndex pool, AbstractTask &task, bool aborted)
	Callback function called when a task is done or cancelled; if returns true, the task will be repeated. More...
void	taskFail (PoolIndex pool, AbstractTask &task, std::exception_ptr exPtr)
	Callback function called when an exception is thrown. More...
void	gpuInitFail (PoolIndex pool, std::exception_ptr exPtr)
	Callback function called when the GPU cannot start. More...

Private Attributes
const Context::Impl &	ctx

Detailed Description

Thread pool event listener.

Definition at line 48 of file context.cpp.

Constructor & Destructor Documentation

ThreadPoolEventListener()

Beatmup::Context::Impl::ThreadPoolEventListener::ThreadPoolEventListener ( const Context::Impl &  ctx )

inline

Definition at line 53 of file context.cpp.

: ctx(ctx) {}

Member Function Documentation

threadCreated()

void Beatmup::Context::Impl::ThreadPoolEventListener::threadCreated ( PoolIndex  pool )

inlinevirtual

Callback function called when a new worker thread is created.

Parameters

pool	Thread pool number in the context

Reimplemented from Beatmup::ThreadPool::EventListener.

Definition at line 55 of file context.cpp.

                                                  {
            if (ctx.eventListener)
                ctx.eventListener->threadCreated(pool);
        };

threadTerminating()

void Beatmup::Context::Impl::ThreadPoolEventListener::threadTerminating ( PoolIndex  pool )

inlinevirtual

Callback function called when a worker thread is terminating.

Parameters

pool	Thread pool number in the context

Reimplemented from Beatmup::ThreadPool::EventListener.

Definition at line 60 of file context.cpp.

                                                      {
            if (ctx.eventListener)
                ctx.eventListener->threadTerminating(pool);
        };

taskDone()

bool Beatmup::Context::Impl::ThreadPoolEventListener::taskDone ( PoolIndex  pool, AbstractTask &  task, bool  aborted  )

inlinevirtual

Callback function called when a task is done or cancelled; if returns true, the task will be repeated.

Parameters

pool	Thread pool number in the context
task	The task
aborted	If true, the task was aborted

Reimplemented from Beatmup::ThreadPool::EventListener.

Definition at line 65 of file context.cpp.

                                                                               {
            if (ctx.eventListener)
                return ctx.eventListener->taskDone(pool, task, aborted);
            return false;
        };

taskFail()

void Beatmup::Context::Impl::ThreadPoolEventListener::taskFail ( PoolIndex  pool, AbstractTask &  task, std::exception_ptr  exPtr  )

inlinevirtual

Callback function called when an exception is thrown.

Parameters

pool	Thread pool number in the context
task	The task that was running when the exception was thrown
exPtr	Exception pointer

Reimplemented from Beatmup::ThreadPool::EventListener.

Definition at line 71 of file context.cpp.

                                                                                         {
            if (ctx.eventListener)
                try {
                    std::rethrow_exception(exPtr);
                }
                catch (const std::exception & ex) {
#if BEATMUP_PLATFORM_ANDROID
                    __android_log_print(ANDROID_LOG_ERROR, "Beatmup",
                        "\n********************************************\n"
                        "Beatmup engine raises exception:\n%s"
                        "\n********************************************\n", ex.what());
#elif BEATMUP_DEBUG
                    std::cout << ex.what() << std::endl;
#endif
                    ctx.eventListener->taskFail(pool, task, ex);
                }
        }

gpuInitFail()

void Beatmup::Context::Impl::ThreadPoolEventListener::gpuInitFail ( PoolIndex  pool, std::exception_ptr  exPtr  )

inlinevirtual

Callback function called when the GPU cannot start.

Parameters

pool	Thread pool number in the context
exPtr	Exception pointer; points to the exception instance occurred when starting up the GPU

Reimplemented from Beatmup::ThreadPool::EventListener.

Definition at line 89 of file context.cpp.

                                                                        {
            if (ctx.eventListener)
                try {
                    std::rethrow_exception(exPtr);
                }
                catch (const std::exception & ex) {
#if BEATMUP_PLATFORM_ANDROID
                    __android_log_print(ANDROID_LOG_ERROR, "Beatmup",
                        "\n********************************************\n"
                        "Beatmup engine was unable to init GPU:\n%s"
                        "\n********************************************\n", ex.what());
#elif BEATMUP_DEBUG
                    std::cout << ex.what() << std::endl;
#endif
                    ctx.eventListener->gpuInitFail(pool, ex);
                }
        }

Member Data Documentation

ctx

const Context::Impl& Beatmup::Context::Impl::ThreadPoolEventListener::ctx

private

Definition at line 50 of file context.cpp.

---

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

• core/context.cpp