Class IoTask

quantum/quantum_io_task.h:34–92

============================================================================================== class IoTask ============================================================================================== @class IoTask. @brief Long running or blocking task running in the IO thread pool. @note For internal use only.

/// @brief Long running or blocking task running in the IO thread pool.
/// @note For internal use only.
class IoTask : public ITask
{
public:
    using Ptr = std::shared_ptr<IoTask>;
    using WeakPtr = std::weak_ptr<IoTask>;
    
    template <class RET, class FUNC, class ... ARGS>
    IoTask(std::true_type,
           std::shared_ptr<Promise<RET>> promise,
           int queueId,
           bool isHighPriority,
           FUNC&& func,
           ARGS&&... args);
    
    template <class RET, class FUNC, class ... ARGS>
    IoTask(std::false_type,
           std::shared_ptr<Promise<RET>> promise,
           int queueId,
           bool isHighPriority,
           FUNC&& func,
           ARGS&&... args);
    
    IoTask(const IoTask& task) = delete;
    IoTask(IoTask&& task) = default;
    IoTask& operator=(const IoTask& task) = delete;
    IoTask& operator=(IoTask&& task) = default;
    
    ~IoTask();
    
    //ITerminate
    void terminate() final;
    
    //ITask
    int run() final;
    void setQueueId(int queueId) final;
    int getQueueId() const final;
    Type getType() const final;
    TaskId getTaskId() const final;
    bool isBlocked() const final;
    bool isSleeping(bool updateTimer = false) final;
    bool isHighPriority() const final;
    bool isSuspended() const final;
    ITask::LocalStorage& getLocalStorage() final;
    
    //===================================
    //           NEW / DELETE
    //===================================
    static void* operator new(size_t size);
    static void operator delete(void* p);
    static void deleter(IoTask* p);
    
private:
    Function<int()>         _func;      //the current runnable io function
    std::atomic_bool        _terminated;
    int                     _queueId;
    bool                    _isHighPriority;
    TaskId                  _taskId;
    ITask::LocalStorage     _localStorage; // local storage of the IO task