Function shard_queues 

pub fn shard_queues(
    num_shards: usize,
    capacity: usize,
) -> (ShardQueues, Vec<Receiver<EncodedChunk>>)

Build the queues: one bounded channel per shard. Returns the shared sender handle and the per-shard receivers for the workers.