threadexceptionadapter.h

Go to the documentation of this file.

#pragma once

#include "threading.h"
#include <mutex>
#include "commonlib/synchronization/locking.h"

BEGIN_NAMESPACE_THREADING

class ThreadExceptionAdapter : public Synchronization::RecursiveLocking
{
public:
    void reset()
    {
        set(std::exception_ptr());
    }

    void set(std::exception_ptr exception)
    {
        std::lock_guard guard(lock);
        this->exceptionPtr = exception;
    }

    void operator=(std::exception_ptr exception)
    {
        set(exception);
    }

    const std::exception_ptr& get() const
    {
        std::lock_guard guard(lock);
        return exceptionPtr;
    }

    const std::exception_ptr& operator*() const
    {
        return get();
    }

    bool operator!() const
    {
        return !isSet();
    }

    bool exceptionOccurred() const
    {
        return isSet();
    };

protected:
    bool isSet() const
    {
        std::lock_guard guard(lock);
        return (this->exceptionPtr != nullptr);
    };

private:
    std::exception_ptr exceptionPtr{nullptr};
};

END_NAMESPACE_THREADING