EntropyEngine::Core::Concurrency::NodeScheduledEvent

EntropyEngine::Core::Concurrency::NodeScheduledEvent

Node has been submitted to the thread pool. More…

#include <WorkGraphEvents.h>

Inherits from EntropyEngine::Core::Concurrency::WorkGraphEvent

Public Functions

	Name
	NodeScheduledEvent(const WorkGraph * g, NodeHandle n)

Public Attributes

	Name
NodeHandle	node The node that was queued.

Additional inherited members

Public Functions inherited from EntropyEngine::Core::Concurrency::WorkGraphEvent

	Name
	WorkGraphEvent(const WorkGraph * g)

Public Attributes inherited from EntropyEngine::Core::Concurrency::WorkGraphEvent

	Name
std::chrono::steady_clock::time_point	timestamp When this event was created.
const WorkGraph *	graph Which graph emitted this event.

Detailed Description

struct EntropyEngine::Core::Concurrency::NodeScheduledEvent;

Node has been submitted to the thread pool.

This fires when a ready node is successfully scheduled into the WorkContractGroup. The node is now in the work queue waiting for a thread to pick it up. Next stop: NodeExecutingEvent when a thread actually starts running it.

// Monitor queue depth
std::atomic<int> queuedNodes{0};

eventBus->subscribe<NodeScheduledEvent>([&queuedNodes](const auto& event) {
    queuedNodes++;
    LOG_DEBUG("Work queue depth: {}", queuedNodes.load());
});

eventBus->subscribe<NodeExecutingEvent>([&queuedNodes](const auto& event) {
    queuedNodes--;
});

Public Functions Documentation

function NodeScheduledEvent

inline NodeScheduledEvent(
    const WorkGraph * g,
    NodeHandle n
)

Public Attributes Documentation

variable node

NodeHandle node;

The node that was queued.

---

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