ThreadBased.hpp

// SPDX-FileCopyrightText: 2025-2026 Vincent Leroy
// SPDX-License-Identifier: MIT
//
// This file is part of dfx.
//
// Licensed under the MIT License. See the LICENSE file in the project root
// for full license information.
 
#pragma once
 
// Standard includes
#include <thread>
 
// Project includes
#include <dfx-core/CustomExecutor.hpp>
#include <dfx-core/Node.hpp>
 
namespace dfx::Node
{
class ThreadBased : public Core::Node
{
public:
    ThreadBased(std::string type, Id id, std::string name);
    ~ThreadBased() override;
 
protected:
    void startImpl() override;
    void stopImpl() override;
 
    virtual void exec(std::stop_token stopToken) = 0;
 
    void tick();
 
protected:
    void setExecutionFlowPolicy(ExecutionFlowPolicy) override;
    void handleMessage(Core::InputPort const &, Core::MessagePtr) override {}
 
private:
    std::atomic_bool _isInDtor{false};
    std::jthread _thread;
};
} // !namespace dfx::Core