Worker.hpp

Go to the documentation of this file.

 
#ifndef ECHOMAP_WORKER_HPP
#define ECHOMAP_WORKER_HPP
 
#include <functional>
#include <thread>
 
#include "ThreadSafeQueue.hpp"
#include "results/WorkerResult.hpp"
#include "tasks/ITask.hpp"
 
namespace echomap
{

class Worker
{
public:
    using ResultCallback = std::function<void()>; 

    explicit Worker(ResultCallback result_callback = {});

    void submit(std::unique_ptr<ITask>&& task);

    [[nodiscard]] bool is_result_available() const;

    std::optional<WorkerResult> try_get_result();

    void clear();
 
private:
    void execute(const std::stop_token& stop_token) noexcept;
 
    ThreadSafeQueue<std::unique_ptr<ITask>> task_queue;
    ThreadSafeQueue<WorkerResult> result_queue;
 
    ResultCallback result_callback; 
    std::jthread worker_thread;     
};
 
} // namespace echomap
 
#endif // ECHOMAP_WORKER_HPP