Struct ExecutorConfig 

pub struct ExecutorConfig {
    pub name: String,
    pub type: String,
    pub num_threads: usize,
    pub affinity: Vec<usize>,
    pub priority: i32,
}

Fields

name: String

执行器名,节点用 executor: 按名引用。必填,且 "default" 是引擎保留名 (那是隐式默认执行器,不写 executor 的节点归它)—— 两者都会在建图期报错。

type: String

"ThreadPoolExecutor"(默认,空也算)= 自有工作线程的线程池; "DelegatingExecutor" = 不拥有线程,把就绪节点交还宿主线程跑 (零并发、顺序确定、Python 算子不抢 GIL,但要宿主进入引擎才推进)。

num_threads: usize

工作线程数。0 视作 1。仅 ThreadPoolExecutor 有意义 —— 配在 DelegatingExecutor 上会报错而不是静默忽略。

affinity: Vec<usize>

CPU 亲和力:worker i 绑到 affinity[i % len] 号核。空 = 不绑(默认)。 仅 Linux/Android 生效;其它平台忽略。用于实时/NUMA 场景固定核、减少迁移抖动。

priority: i32

实时优先级(SCHED_FIFO,1..=99)。0 = 不动(默认,普通分时)。 尽力而为:设实时调度需 CAP_SYS_NICE/root,拿不到就静默降级。仅 Linux/Android。

Trait Implementations

impl Clone for ExecutorConfig

fn clone(&self) -> ExecutorConfig

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for ExecutorConfig

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for ExecutorConfig

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.