Task.h

Go to the documentation of this file.

 
#pragma once
#include "Future.h"
#include "catapult/utils/TimeSpan.h"
#include <functional>
#include <string>
 
namespace catapult { namespace thread {
 
    enum class TaskResult {
        Continue,
 
        Break
    };
 
    using TaskCallback = supplier<thread::future<TaskResult>>;
 
    using DelayGenerator = supplier<utils::TimeSpan>;
 
    struct Task {
        utils::TimeSpan StartDelay;
 
        DelayGenerator NextDelay;
 
        TaskCallback Callback;
 
        std::string Name;
    };
 
    DelayGenerator CreateUniformDelayGenerator(const utils::TimeSpan& delay);
 
    DelayGenerator CreateIncreasingDelayGenerator(
            const utils::TimeSpan& minDelay,
            uint32_t numPhaseOneRounds,
            const utils::TimeSpan& maxDelay,
            uint32_t numTransitionRounds);
 
    Task CreateNamedTask(const std::string& name, const TaskCallback& callback);
}}