Struct exr::block::writer::ParallelBlocksCompressor

pub struct ParallelBlocksCompressor<'w, W> { /* private fields */ }

Compress blocks to a chunk writer with multiple threads.

Implementations

impl<'w, W> ParallelBlocksCompressor<'w, W>where W: 'w + ChunksWriter,

pub fn new( meta: &'w MetaData, chunks_writer: &'w mut W, pool: ThreadPool ) -> Option<Self>

New blocks writer. Returns none if sequential compression should be used.

pub fn inner_chunks_writer(&'w self) -> &'w W

This is where the compressed blocks are written to.

pub fn write_all_queued_chunks(&mut self) -> UnitResult

Wait until all currently compressing chunks in the compressor have been written.

pub fn add_block_to_compression_queue( &mut self, index_in_header_increasing_y: usize, block: UncompressedBlock ) -> UnitResult

Add a single block to the compressor queue. The index of the block must be in increasing line order. When calling this function for the last block, this method waits until all the blocks have been written. This only works when you write as many blocks as the image expects, otherwise you can use wait_for_all_remaining_chunks. Waits for a block from the queue to be written, if the queue already has enough items.

Trait Implementations

impl<'w, W: Debug> Debug for ParallelBlocksCompressor<'w, W>

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

Formats the value using the given formatter.