Skip to content

EntropyEngine::Core::Concurrency::NodeScheduler::Callbacks

EntropyEngine::Core::Concurrency::NodeScheduler::Callbacks

Section titled “EntropyEngine::Core::Concurrency::NodeScheduler::Callbacks”

Lifecycle hooks for monitoring node execution flow. More…

#include <NodeScheduler.h>

Name
std::function< void(NodeHandle, std::chrono::steady_clock::time_point)>onNodeYieldedUntil
Node yielded until specific time.
std::function< void(NodeHandle)>onNodeYielded
Node yielded execution (will reschedule immediately).
std::function< void(NodeHandle)>onNodeScheduled
Node successfully entered work queue.
std::function< void(NodeHandle, std::exception_ptr)>onNodeFailed
Node threw an exception.
std::function< void(NodeHandle)>onNodeExecuting
Node started executing (worker picked it up).
std::function< void(NodeHandle)>onNodeDropped
Node dropped (deferred queue overflow).
std::function< void(NodeHandle)>onNodeDeferred
Node queued due to lack of capacity.
std::function< void(NodeHandle)>onNodeCompleted
Node finished successfully.
struct EntropyEngine::Core::Concurrency::NodeScheduler::Callbacks;

Lifecycle hooks for monitoring node execution flow.

These callbacks let you track what’s happening to your nodes as they flow through the scheduling system. Perfect for debugging, profiling, or building visualization tools. All callbacks are optional - only set the ones you need.

std::function< void(NodeHandle, std::chrono::steady_clock::time_point)> onNodeYieldedUntil;

Node yielded until specific time.

std::function< void(NodeHandle)> onNodeYielded;

Node yielded execution (will reschedule immediately).

std::function< void(NodeHandle)> onNodeScheduled;

Node successfully entered work queue.

std::function< void(NodeHandle, std::exception_ptr)> onNodeFailed;

Node threw an exception.

std::function< void(NodeHandle)> onNodeExecuting;

Node started executing (worker picked it up).

std::function< void(NodeHandle)> onNodeDropped;

Node dropped (deferred queue overflow).

std::function< void(NodeHandle)> onNodeDeferred;

Node queued due to lack of capacity.

std::function< void(NodeHandle)> onNodeCompleted;

Node finished successfully.


Updated on 2026-01-26 at 17:14:35 -0500