Struct kernel::kasync::executor::workqueue::Executor

pub struct Executor { /* private fields */ }

An executor backed by a work queue.

Examples

The following example runs two tasks on the shared system workqueue.

use kernel::kasync::executor::workqueue::Executor;
use kernel::spawn_task;
use kernel::workqueue;

fn example_shared_workqueue() -> Result {
    let mut handle = Executor::try_new(workqueue::system())?;
    spawn_task!(handle.executor(), async {
        pr_info!("First workqueue task\n");
    })?;
    spawn_task!(handle.executor(), async {
        pr_info!("Second workqueue task\n");
    })?;
    handle.detach();
    Ok(())
}

Implementations

impl Executor

pub fn try_new(wq: &'static Queue) -> Result<AutoStopHandle<Self>>

Creates a new workqueue-based executor using a static work queue.

pub fn try_new_owned(wq: BoxedQueue) -> Result<AutoStopHandle<Self>>

Creates a new workqueue-based executor using an owned (boxed) work queue.

Trait Implementations

impl Executor for Executor

fn spawn(
    self: RefBorrow<'_, Self>,
    key: &'static LockClassKey,
    future: impl Future + 'static + Send
) -> Result<Ref<dyn Task>>

Starts executing a task defined by the given future.

fn stop(&self)

Stops the executor.

impl Send for Executor

impl Sync for Executor