Struct HashPool 

pub struct HashPool { /* private fields */ }

A thread pool dedicated to CPU-bound piece hash verification.

Uses tokio::sync::mpsc for async job submission and std::sync::mpsc internally for the blocking worker threads. Results are sent back via per-torrent tokio::sync::mpsc::Sender carried in each HashJob.

Implementations

impl HashPool

pub fn new(num_workers: usize, job_capacity: usize) -> Self

Create a new hash pool with num_workers threads.

job_capacity bounds the submission channel (backpressure if full).

Must be called from within a tokio runtime — spawns a bridge task.

pub async fn submit(&self, job: HashJob) -> Result<(), HashJob>

Submit a hash job. Returns Err if the pool has been shut down.

Errors

Returns an error if the session is shut down.

Trait Implementations

impl Debug for HashPool

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

Formats the value using the given formatter.

impl Drop for HashPool

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.