Struct TaskQueue 

pub struct TaskQueue<H: Handle> { /* private fields */ }

Implementations

impl<H: Handle> TaskQueue<H>

pub fn new<'a>(tasks: impl Iterator<Item = &'a Range<u64>>) -> Self

pub fn finish_work(&self, task: &Task) -> usize

仅供 Worker 线程在任务完成后调用

pub fn cancel(&self, task: &Task) -> usize

用于从外部取消任务

pub fn add(&self, task: Task)

pub fn steal(&self, task: &Task, min_chunk_size: u64) -> bool

pub fn set_threads<E: Executor<Handle = H>>( &self, threads: usize, min_chunk_size: u64, executor: Option<&E>, ) -> Option<()>

当线程数需要增加时，但 executor 为空时，返回 None

pub fn handles<F, R>(&self, f: F) -> R

where F: FnOnce(&mut dyn Iterator<Item = &mut H>) -> R,

Trait Implementations

impl<H: Handle> Clone for TaskQueue<H>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<H: Debug + Handle> Debug for TaskQueue<H>

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

Formats the value using the given formatter.