Struct Worker 

pub struct Worker { /* private fields */ }

A thread-pinned io_uring executor: the ring, a timer heap, and a local (!Send) task set, driven by a caller-owned loop.

Create one per thread, keep it on that thread (!Send), and drive it with block_on. Everything else reaches the worker through Handle: UDP sockets, timers, spawned tasks. Wakes from other threads (any Waker this worker minted) are an atomic store plus, only while the worker is parked, one futex syscall.

Dropping the worker makes a bounded attempt to submit the SQEs its last turn staged and drain their completions. A datagram already handed to a udp::Socket is included in that submission attempt, while operation storage that the kernel might still access is safely leaked if teardown cannot finish. It runs no tasks, though, so work a task has merely been asked for is not performed: a QUIC close is queued on its connection and framed by the driver task, so keep driving until the close is published rather than stopping the worker on the call that asked for it.

Implementations

impl Worker

pub fn new(config: Config) -> Result<Self, Error>

Set up the ring, refusing kernels below Linux 6.12.

The floor buys incremental provided-buffer consumption, the absolute park timeout, and batched minimum waits with one code path; there is deliberately no fallback (use the tokio stack instead).

pub fn handle(&self) -> Handle

A cloneable handle for spawning, binding sockets, and minting timers.

pub fn block_on<F: Future>(&mut self, future: F) -> Result<F::Output, Error>

Drive the worker until future resolves.

Spawned tasks run alongside it and keep running across calls; they do not keep block_on alive. An Err means the ring itself failed, which is fatal to the worker.

Trait Implementations

impl Debug for Worker

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

Formats the value using the given formatter.

impl Drop for Worker

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.