Crate runtime

Available on crate feature runtime only.

Expand description

The compio runtime.

let ans = compio_runtime::Runtime::new().unwrap().block_on(async {
    println!("Hello world!");
    42
});
assert_eq!(ans, 42);

Modules§

Attacher: Attach a handle to the driver of current thread.
BorrowedBuffer: Buffer borrowed from buffer pool
BufferPool: Buffer pool
CancelToken: A token that can be used to cancel multiple operations at once.
OptWaker: An optimized waker that avoids unnecessary wake-ups on the same thread.
Runtime: The async runtime of compio.
RuntimeBuilder: Builder for Runtime.
Submit: Returned Future for Runtime::submit.
SubmitMulti: Returned [Stream] for Runtime::submit_multi.
Task: A spawned task.

register_files: Register file descriptors for fixed-file operations with the current runtime’s io_uring instance.
spawn: Spawns a new asynchronous task, returning a Task for it.
spawn_blocking: Spawns a blocking task in a new thread, and wait for it.
submit: Submit an operation to the current runtime, and return a future for it.
submit_multi: Submit a multishot operation to the current runtime, and return a stream for it.
unregister_files: Unregister previously registered file descriptors from the current runtime’s io_uring instance.

JoinHandle: Type alias for Task<Result<T, Box<dyn Any + Send>>>, which resolves to an Err when the spawned future panicked.