Struct pooled_writer::Pool

pub struct Pool { /* private fields */ }

A Pool orchestrates two different threadpools, a compressor pool and a writer pool.

The pool is suitable for scenarios where there are many more writers than threads, efficiently managing resources for M writers to N threads.

Implementations

impl Pool

pub fn new<W, C>(
    num_writer_threads: usize,
    num_compressor_threads: usize,
    compression_level: u8,
    writers: Vec<W>
) -> Result<(Self, Vec<PooledWriter>), PoolError> where
    W: Write + Send + 'static,
    C: Compressor, 

Create a running pool along with an associated set of pooled_writers.

Arguments

• num_writer_threads - The number of writer threads to use in the writer pool.
• num_compressor_threads - The number of compressor threads to use in the compressor pool.
• compression_level - The compression level to use for the Compressor pool.
• writers - The writers to exchange for PooledWriters.

pub fn stop_pool(&mut self) -> Result<(), PoolError>

Shutdown all pool resources and close all channels.

Ideally the PooledWriters should all have been flushed first, that is up to the user. Any further attempts to send to the Pool will return an error.

Trait Implementations

impl Debug for Pool

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

Formats the value using the given formatter.

impl Drop for Pool

fn drop(&mut self)

Executes the destructor for this type.