Struct ParallelTranscodeExecutor 

pub struct ParallelTranscodeExecutor { /* private fields */ }

Parallel batch proxy transcode executor powered by Rayon.

Jobs from a ProxyTranscodeQueue are dispatched to Rayon’s global or a custom thread pool using work-stealing. Completed results are collected in a thread-safe results vector.

Implementations

impl ParallelTranscodeExecutor

pub fn new(config: ParallelExecutorConfig) -> Self

Create a new executor with the given configuration.

pub fn execute_batch( &self, queue: &ProxyTranscodeQueue, ) -> Vec<ParallelJobResult>

Execute all Queued jobs from queue in parallel and return results.

The queue is not mutated; callers should apply results using ParallelTranscodeExecutor::apply_results if they wish to update statuses.

Errors

Never errors at the executor level; individual job failures are captured in ParallelJobResult::success / ParallelJobResult::error.

pub fn apply_results( queue: &mut ProxyTranscodeQueue, results: &[ParallelJobResult], )

Apply a batch of results back to a mutable queue, updating job statuses.