UT_ThreadIOPool.h

Go to the documentation of this file.

/*
 * PROPRIETARY INFORMATION.  This software is proprietary to
 * Side Effects Software Inc., and is not to be reproduced,
 * transmitted, or disclosed in any way without written permission.
 *
 * NAME:        UT_ThreadIOPool.h
 *
 * COMMENTS:
 *                      
 *
 */

#ifndef __UT_THREADIOPOOL_H__
#define __UT_THREADIOPOOL_H__

#include "UT_API.h"

#include "UT_BoostAsio.h"

#include "UT_Assert.h"
#include "UT_IOContext.h"
#include "UT_Lock.h"
#include "UT_Thread.h"
#include "UT_UniquePtr.h"

/// By default only the subsystem should be able to stop the pool. Use
/// UT_ThreadIOPool instead of you need control over starting and stopping.
class UT_API UT_PrivateThreadIOPool
{
public:
    UT_PrivateThreadIOPool() = default;

    ASIO_IOContext::executor_type executor()
    {
        return myIOContext.get_executor();
    }

    void start(int nthreads);

protected:
    void stop();

private:
    friend class UT_SubSystem;

    static void runIOContextLoop(UT_PrivateThreadIOPool& pool);

    mutable UT_Lock myLock;
    UT_UniquePtr<UT_StdThreadGroup<true>> myThreadGroup;
    UT_IOContext myIOContext;
    UT_UniquePtr<hboost::asio::executor_work_guard<
            hboost::asio::io_context::executor_type>>
            myIOWorkGuard;
};

class UT_API UT_ThreadIOPool : public UT_PrivateThreadIOPool
{
public:
    using UT_PrivateThreadIOPool::stop;
};
#endif // __UT_THREADIOPOOL_H__