Struct ThreadPool 

pub struct ThreadPool { /* private fields */ }

Implementations

impl ThreadPool

pub fn new( name: &str, num_threads: usize, affinity: Vec<usize>, priority: i32, ) -> Self

pub fn name(&self) -> &str

pub fn num_threads(&self) -> usize

pub fn affinity(&self) -> &[usize]

pub fn priority(&self) -> i32

pub fn start(&self, graph: Weak<GraphInner>)

拉起工作线程。必须在 Arc<GraphInner> 已存在之后调用。

pub fn submit(&self, node: NodeId) -> bool

投递一个就绪节点。关停后返回 false。

pub fn submit_source_wake( &self, node: NodeId, generation: u64, delay: Duration, ) -> bool

pub fn pending(&self) -> usize

pub fn clear_delayed(&self)

pub fn reset_stats(&self)

pub fn shutdown(&self)

关停并 join。幂等。

Trait Implementations

impl Drop for ThreadPool

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.