#multiprocessing #communication #seamless #synchronously #cross-process #crossmist

macro crossmist-derive

Efficient and seamless cross-process communication, both synchronously and asynchronously

8 releases (2 stable)

1.0.2 May 3, 2024
1.0.0 May 1, 2024
0.2.4 Jan 25, 2024
0.2.0 Dec 19, 2023
0.1.3 Jul 29, 2023

#8 in #cross-process

44 downloads per month
Used in crossmist

MIT license

23KB
471 lines

crossmist

License: MIT docs.rs crates.io

crossmist provides efficient and seamless cross-process communication for Rust. It provides semantics similar to std::thread::spawn and single-producer single-consumer channels, both synchronously and asynchronously.

Installation

$ cargo add crossmist

Or add the following to your Cargo.toml:

crossmist = "1.1.1"

Documentation

Check out docs.rs.

Motivational examples

This crate allows you to easily perform computations in another process without creating a separate executable or parsing command line arguments manually. For example, the simplest example, computing a sum of several numbers in a one-shot subprocess, looks like this:

#[crossmist::main]
fn main() {
    println!("5 + 7 = {}", add.run(vec![5, 7]).unwrap());
}

#[crossmist::func]
fn add(nums: Vec<i32>) -> i32 {
    nums.into_iter().sum()
}

This crate also supports long-lived tasks with constant cross-process communication:

#[crossmist::main]
fn main() {
    let (mut ours, theirs) = crossmist::duplex().unwrap();
    add.spawn(theirs).expect("Failed to spawn child");
    for i in 1..=5 {
        for j in 1..=5 {
            println!("{i} + {j} = {}", ours.request(&vec![i, j]).unwrap());
        }
    }
}

#[crossmist::func]
fn add(mut chan: crossmist::Duplex<i32, Vec<i32>>) {
    while let Some(nums) = chan.recv().unwrap() {
        chan.send(&nums.into_iter().sum());
    }
}

Almost arbitrary objects can be passed between processes and across channels, including file handles, sockets, and other channels.

Dependencies

~2MB
~44K SLoC