CustomExecutor.hpp

// SPDX-FileCopyrightText: 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
 
// Project includes
#include <dfx-runtime-api/NodeTaskExecutor.hpp>
#include <dfx-utilities/sync-queues/PriorityStableQueue.hpp>
 
namespace dfx::Core
{
class CustomExecutor : public Runtime::Api::NodeTaskExecutor
{
public:
    bool pushTask(Runtime::Api::TaskPtr task) override;

    std::size_t pushTasks(std::span<Runtime::Api::TaskPtr> tasks) override;

    void processNextTask();

    void processAllPendingTasks();
 
private:
    Utils::PriorityStableQueue<Runtime::Api::TaskPtr> _queue;
};
} // !namespace dfx::Core