Executor.h

Go to the documentation of this file.

 
// SPDX-License-Identifier: LGPL-2.1-or-later
 
#ifndef TASKOLIB_EXECUTOR_H_
#define TASKOLIB_EXECUTOR_H_
 
#include <future>
#include <memory>
 
#include "taskolib/CommChannel.h"
#include "taskolib/Context.h"
#include "taskolib/Sequence.h"
#include "taskolib/StepIndex.h"
 
namespace task {
 
class Executor
{
public:
    Executor();
 
    // Not copyable but movable (you can't copy a future)
    Executor(Executor const&) = delete;
    Executor& operator=(Executor const&) = delete;
    Executor(Executor&&) = default;
    Executor& operator=(Executor&&) = default;
 
    ~Executor() { cancel(); };
 
    void cancel();
 
    void cancel(Sequence& sequence);
 
    void run_asynchronously(Sequence& sequence, Context context);
 
    void run_single_step_asynchronously(Sequence& sequence, Context context,
                                        StepIndex step_index);
 
    bool update(Sequence& sequence);
 
    VariableTable get_context_variables() { return context_.variables; }
 
private:
    std::shared_ptr<CommChannel> comm_channel_;
 
    std::future<VariableTable> future_;
 
    Context context_;
 
    void launch_async_execution(Sequence& sequence, Context context,
                                OptionalStepIndex step_index);
 
    bool is_busy();
};
 
} // namespace task
 
#endif