Struct Executor 

pub struct Executor { /* private fields */ }

Top-level executor. One per process is the typical case.

Implementations

impl Executor

pub fn builder() -> ExecutorBuilder

Start a new builder.

pub fn channel<T: Payload>( &mut self, name: &str, ) -> Result<Arc<Channel<T>>, ExecutorError>

Open or create a pub/sub channel bound to this executor’s node.

pub fn service<Req, Resp>( &mut self, name: &str, ) -> Result<Arc<Service<Req, Resp>>, ExecutorError>

where Req: Payload, Resp: Payload,

Open or create a request/response service bound to this executor’s node.

pub fn add( &mut self, item: impl ExecutableItem, ) -> Result<TaskId, ExecutorError>

Add an item to the executor with an auto-generated id.

pub fn add_with_id( &mut self, id: impl Into<TaskId>, item: impl ExecutableItem, ) -> Result<TaskId, ExecutorError>

Add an item with a user-supplied id.

The item’s ExecutableItem::task_id override takes precedence over the caller-supplied id, which itself takes precedence over the auto-generated id assigned by Executor::add.

pub fn add_chain<I, C>(&mut self, items: C) -> Result<TaskId, ExecutorError>

where I: ExecutableItem, C: IntoIterator<Item = I>,

Add a sequential chain of items. Only the head item’s declare_triggers is consulted; non-head triggers are ignored with a tracing warn.

pub fn add_chain_with_id<I, C>( &mut self, id: impl Into<TaskId>, items: C, ) -> Result<TaskId, ExecutorError>

where I: ExecutableItem, C: IntoIterator<Item = I>,

Like Executor::add_chain but with a user-supplied id.

pub fn stoppable(&self) -> Stoppable

Returns a Stoppable handle that is waker-aware from the moment the executor is built. Clone before calling run() — any clone taken at any time will wake the WaitSet when stop() is called.

pub const fn iceoryx_node(&self) -> &Node<Service>

Borrow the underlying iceoryx2 node (escape hatch for power users).

pub fn add_graph(&mut self) -> ExecutorGraphBuilder<'_>

Begin building a graph. Call .build() on the returned builder to register the graph as a task.

impl Executor

pub fn run(&mut self) -> Result<(), ExecutorError>

Run the executor until Stoppable::stop is called or a task signals stop via crate::Context::stop_executor.

Errors

Returns the first ExecutorError surfaced during dispatch:

• ExecutorError::Item if any item returns Err or panics.
• ExecutorError::Iceoryx2 if a WaitSet operation fails.
• ExecutorError::AlreadyRunning if the executor is already running.

If multiple items error in the same dispatch iteration, only the first is preserved; subsequent errors are discarded silently. To observe every error, attach an Observer and read errors via Observer::on_app_error.

pub fn run_for(&mut self, max: Duration) -> Result<(), ExecutorError>

Run for at most max wall-clock duration, then return.

Errors

Returns the first ExecutorError surfaced during dispatch:

• ExecutorError::Item if any item returns Err or panics.
• ExecutorError::Iceoryx2 if a WaitSet operation fails.
• ExecutorError::AlreadyRunning if the executor is already running.

If multiple items error in the same dispatch iteration, only the first is preserved; subsequent errors are discarded silently. To observe every error, attach an Observer and read errors via Observer::on_app_error.

pub fn run_n(&mut self, n: usize) -> Result<(), ExecutorError>

Run until n full barrier-cycles (WaitSet wakeups) have completed.

Errors

Returns the first ExecutorError surfaced during dispatch:

• ExecutorError::Item if any item returns Err or panics.
• ExecutorError::Iceoryx2 if a WaitSet operation fails.
• ExecutorError::AlreadyRunning if the executor is already running.

If multiple items error in the same dispatch iteration, only the first is preserved; subsequent errors are discarded silently. To observe every error, attach an Observer and read errors via Observer::on_app_error.

pub fn run_until<F: FnMut() -> bool>( &mut self, predicate: F, ) -> Result<(), ExecutorError>

Run until predicate() returns true. Checked after each WaitSet wakeup.

Errors

Returns the first ExecutorError surfaced during dispatch:

• ExecutorError::Item if any item returns Err or panics.
• ExecutorError::Iceoryx2 if a WaitSet operation fails.
• ExecutorError::AlreadyRunning if the executor is already running.

If multiple items error in the same dispatch iteration, only the first is preserved; subsequent errors are discarded silently. To observe every error, attach an Observer and read errors via Observer::on_app_error.

Trait Implementations

impl Send for Executor