Struct Task 

pub struct Task {
    pub stage: ContigProcessingStage,
    pub sample_name: String,
    pub contig_name: String,
    pub sequence: Contig,
}

A task for the worker queue

This matches C++ AGC’s task_t typedef (agc_compressor.h:656):

using task_t = tuple<contig_processing_stage_t, string, string, contig_t>;

Fields:

• stage: What type of processing this task needs
• sample_name: Which sample this contig belongs to
• contig_name: Contig identifier (chromosome name, etc.)
• sequence: The actual sequence data

For synchronization tasks (Registration, NewSplitters):

• sample_name, contig_name, and sequence are empty
• Workers detect sync tasks and enter barrier synchronization

Fields

stage: ContigProcessingStage

sample_name: String

contig_name: String

sequence: Contig

Implementations

impl Task

pub fn new_contig( sample_name: String, contig_name: String, sequence: Contig, stage: ContigProcessingStage, ) -> Self

Create a new contig processing task

pub fn new_sync(stage: ContigProcessingStage) -> Self

Create a synchronization barrier task

This is sent N times (once per worker) to trigger barrier synchronization. Matches C++ AGC’s EmplaceManyNoCost() pattern (agc_compressor.cpp:2197).

pub fn is_sync(&self) -> bool

Check if this is a synchronization task

Trait Implementations

impl Clone for Task

fn clone(&self) -> Task

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for Task

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

Formats the value using the given formatter.

impl PartialEq for Task

fn eq(&self, other: &Task) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Eq for Task

impl StructuralPartialEq for Task