Struct DelegatingExecutor 

pub struct DelegatingExecutor { /* private fields */ }

委托执行器:一个线程都不拥有,把就绪节点交还宿主线程跑。

submit 只入队，真正执行发生在宿主进入阻塞接口或主动调用 Graph::pump_step 时。 同一张图的委托任务由图级原子闸门保证零并发。

Implementations

impl DelegatingExecutor

pub fn new(name: &str) -> Self

pub fn name(&self) -> &str

pub fn submit(&self, node: NodeId) -> bool

入队待宿主抽取。委托执行器没有已关停状态，故恒返回 true。

pub fn pending(&self) -> usize

pub fn take(&self) -> Option<NodeId>

弹一个待办交给宿主线程跑;None = 队列空。

pub fn complete(&self, execution: Option<Duration>)

pub fn clear(&self)

清空队列(reset 用:上一轮的残留不能带进下一轮)。

pub fn reset_stats(&self)