Struct tikv_util::yatp_pool::future_pool::FuturePool

pub struct FuturePool {
    pool: Arc<ThreadPool<TaskCell>>,
    env: Env,
    pool_size: usize,
    max_tasks: usize,
}

Fields

pool: Arc<ThreadPool<TaskCell>>

env: Env

pool_size: usize

max_tasks: usize

Implementations

impl FuturePool

pub fn from_pool(
    pool: ThreadPool<TaskCell>,
    name: &str,
    pool_size: usize,
    max_tasks: usize
) -> Self

pub fn get_pool_size(&self) -> usize

Gets inner thread pool size.

pub fn get_running_task_count(&self) -> usize

Gets current running task count.

fn gate_spawn(&self) -> Result<(), Full>

pub fn spawn<F>(&self, future: F) -> Result<(), Full> where
    F: Future + Send + 'static, 

Spawns a future in the pool.

pub fn spawn_handle<F>(
    &self,
    future: F
) -> Result<impl Future<Output = Result<F::Output, Canceled>>, Full> where
    F: Future + Send + 'static,
    F::Output: Send, 

Spawns a future in the pool and returns a handle to the result of the future.

The future will not be executed if the handle is not polled.

Trait Implementations

impl AssertSend for FuturePool

impl AssertSync for FuturePool

impl Clone for FuturePool

fn clone(&self) -> FuturePool

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for FuturePool

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

Formats the value using the given formatter.