Struct conch_runtime::env::ThreadPoolAsyncIoEnv

pub struct ThreadPoolAsyncIoEnv { /* fields omitted */ }

An AsyncIoEnvironment implementation that uses a threadpool for doing reads and writes on synchronous/blocking FileDesc handles.

This is a pretty costly implementation which may be required on systems that do not support asynchronous read/write operations (easily or at all). If running on a system that supports more efficient async operations, it is strongly encouraged to use an alternative implementation.

Note: Caller should ensure that any FileDesc handles passed into this environment are not configured for asynchronous operations, otherwise operations will fail with a WouldBlock error. This is done to avoid burning CPU cycles while spinning on read/write operations.

Methods

impl ThreadPoolAsyncIoEnv

pub fn new(size: usize) -> Self

Creates a new thread pool with size worker threads associated with it.

pub fn new_num_cpus() -> Self

Creates a new thread pool with a number of workers equal to the number of CPUs on the host.

Trait Implementations

impl Clone for ThreadPoolAsyncIoEnv

fn clone(&self) -> ThreadPoolAsyncIoEnv

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl SubEnvironment for ThreadPoolAsyncIoEnv

fn sub_env(&self) -> Self

Create a new sub-environment, which starts out idential to its parent, but any changes on the new environment will not be reflected on the parent.

impl Debug for ThreadPoolAsyncIoEnv

fn fmt(&self, fmt: &mut Formatter) -> Result

Formats the value using the given formatter.

impl AsyncIoEnvironment for ThreadPoolAsyncIoEnv

type Read = ReadAsync

An async/futures-aware Read adapter around a FileDesc.

type WriteAll = CpuFuture<(), IoError>

An future that represents writing data into a FileDesc.

fn read_async(&mut self, fd: FileDesc) -> Self::Read

Creates a futures-aware adapter to read data from a FileDesc asynchronously.

fn write_all(&mut self, fd: FileDesc, data: Vec<u8>) -> Self::WriteAll

Creates a future for writing data into a FileDesc.

fn write_all_best_effort(&mut self, fd: FileDesc, data: Vec<u8>)

Asynchronously write the contents of data to a FileDesc in the background on a best effort basis (e.g. the implementation can give up due to any (appropriately) unforceen errors like broken pipes).