Struct CompletionPort

pub struct CompletionPort { /* private fields */ }

Implementations

impl CompletionPort

pub fn new(num_threads: u32) -> Result<Self>

Create a CompletionPort with specify then concurrent

pub fn add<A: AsHandle>(&self, token: usize, io_object: &A) -> Result<()>

Register a handle and token with CompletionPort. The same token and handle cannot be registered in CompletionPort again unless the handle has been closed.

pub fn get(&self, timeout: Option<Duration>) -> Result<OperationalResult>

pub fn get_many( &self, size: usize, timeout: Option<Duration>, ) -> Result<Vec<OperationalResult>>

Get many result by Context lists, and return OperationalResult lists.

pub fn post(&self, result: OperationalResult) -> Result<()>

Trait Implementations

impl Drop for CompletionPort

fn drop(&mut self)

Executes the destructor for this type.

impl Send for CompletionPort

impl Sync for CompletionPort