Struct BlockingExecutor 

pub struct BlockingExecutor { /* private fields */ }

Implementations

impl BlockingExecutor

pub fn worker_count(&self) -> usize

pub fn reserved_bytes(&self) -> usize

pub fn scoped( &self, resources: Arc<ResourceLedger>, admission_open: Arc<AtomicBool>, admission_gate: Arc<Mutex<()>>, ) -> Self

Share the fixed workers and queue while charging admission to a child ledger (which atomically charges its process parent too).

pub fn submit<F>( &self, reserved_bytes: usize, operation: F, ) -> Result<(), BlockingJobError>

where F: FnOnce() + Send + 'static,

pub async fn run<T, F>( &self, reserved_bytes: usize, operation: F, ) -> Result<T, BlockingJobError>

where T: Send + 'static, F: FnOnce() -> T + Send + 'static,

pub fn run_sync<T, F>( &self, reserved_bytes: usize, timeout: Duration, operation: F, ) -> Result<T, BlockingJobError>

where T: Send + 'static, F: FnOnce() -> T + Send + 'static,

Trait Implementations

impl Clone for BlockingExecutor

fn clone(&self) -> BlockingExecutor

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for BlockingExecutor

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

Formats the value using the given formatter.