Struct tikv_util::yatp_pool::FuturePool

[+] Show declaration

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[+]

[+] Show hidden undocumented items

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[+]

[+] Show hidden undocumented items

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

Formats the value using the given formatter.