Struct MPICommunicator 

pub struct MPICommunicator { /* private fields */ }

MPI communicator abstraction for quantum operations

Implementations

impl MPICommunicator

pub fn new() -> QuantRS2Result<Self>

Create a new MPI communicator

pub fn with_config(rank: usize, size: usize, backend: MPIBackend) -> Self

Create communicator with specific configuration

pub const fn rank(&self) -> usize

Get rank of this process

pub const fn size(&self) -> usize

Get total number of processes

pub fn barrier(&self) -> QuantRS2Result<()>

Barrier synchronization: every rank sharing this communicator’s SimulatedMPIState must call this before any of them proceeds.

pub fn sendrecv( &self, send_data: &[Complex64], partner: usize, ) -> QuantRS2Result<Vec<Complex64>>

Send and receive data with a partner rank (real rendezvous exchange for the Simulated backend).

pub fn gather<T: Clone + Send + 'static>( &self, local_data: &[T], root: usize, ) -> QuantRS2Result<Vec<T>>

Gather data from all ranks to root (root receives every rank’s contribution concatenated in rank order; other ranks get their own data back, matching real MPI_Gather semantics).

pub fn broadcast<T: Clone + Send + 'static>( &self, data: &[T], root: usize, ) -> QuantRS2Result<Vec<T>>

Broadcast data from root to all ranks.

pub fn allreduce( &self, local_data: &[f64], op: ReduceOp, ) -> QuantRS2Result<Vec<f64>>

Allreduce operation: elementwise-reduce local_data across every rank and return the reduced vector to all of them.

Trait Implementations

impl Debug for MPICommunicator

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

Formats the value using the given formatter.