AsyncTasksManager.h

Go to the documentation of this file.

/*--------------------------------------------------------------------------------------+
|
|   Supplied under applicable software license agreement.
|
|   Copyright (c) 2018 Bentley Systems, Incorporated. All rights reserved.
|
+---------------------------------------------------------------------------------------*/
#pragma once

#include <Bentley/Tasks/Tasks.h>
#include <Bentley/Tasks/ITaskRunner.h>
#include <Bentley/BeThread.h>
#include <Bentley/bmap.h>
#include <condition_variable>
#include <mutex>

BEGIN_BENTLEY_TASKS_NAMESPACE

struct AsyncTask;
struct WorkerThreadPool;
struct ITaskScheduler;

/*--------------------------------------------------------------------------------------+
* @bsiclass                                                     Bentley Systems
+---------------+---------------+---------------+---------------+---------------+------*/
struct AsyncTasksManager
    {
    private:
        AsyncTasksManager ();

    public:
        BENTLEYDLL_EXPORT static std::shared_ptr<ITaskRunner> GetTaskRunner (intptr_t threadId);

        BENTLEYDLL_EXPORT static std::shared_ptr<ITaskRunner> GetCurrentTaskRunner ();
        BENTLEYDLL_EXPORT static std::shared_ptr<AsyncTask>   GetCurrentThreadAsyncTask ();

        BENTLEYDLL_EXPORT static std::shared_ptr<ITaskScheduler> GetDefaultScheduler ();

        BENTLEYDLL_EXPORT static void StopThreadingAndWait();
        
        BENTLEYDLL_EXPORT static void SetWaitForThreadsWhenStopped(bool value);
    };

END_BENTLEY_TASKS_NAMESPACE