Struct ThreadingProvider 

pub struct ThreadingProvider { /* private fields */ }

Threading provider

Implementations

impl ThreadingProvider

pub fn new() -> Self

Create a new threading provider

pub async fn execute_cpu_task<F, T>(&self, task: F) -> Result<T>

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

Execute CPU-intensive task

pub async fn execute_io_task<F, T>(&self, task: F) -> Result<T>

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

Execute I/O task

pub fn create_mutex<T>(&self, value: T) -> Arc<Mutex<T>>

Create a new mutex

pub fn create_rwlock<T>(&self, value: T) -> Arc<RwLock<T>>

Create a new read-write lock

pub fn cpu_count(&self) -> usize

Get CPU count

Trait Implementations

impl Debug for ThreadingProvider

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

Formats the value using the given formatter.

impl Default for ThreadingProvider

fn default() -> Self

Returns the “default value” for a type.