4 releases (2 breaking)

Uses old Rust 2015

0.3.1 Oct 11, 2017
0.3.0 Jun 25, 2017
0.2.0 Jun 11, 2017
0.1.0 Jun 6, 2017

#787 in Concurrency


Used in snail

MIT license

12KB
182 lines

mrsc Build Status Crates.io

mpsc with requests. This is a basic building block based on rusts mpsc if you have multiple workers that need to execute transactions on a shared state, without having to share your state struct across all threads. Beware that transactions are blocking, so it's recommended to avoid expensive code in the transaction handler.

Installation

Add this to your Cargo.toml dependency list:

[dependencies]
mrsc = "0.3"

Add this to your crate root:

extern crate msrc

Example

use mrsc;
use std::thread;

let server: mrsc::Server<u32, String> = mrsc::Server::new();
let channel = server.pop();

thread::spawn(move || {
    let req = server.recv().unwrap();
    let reply = {
        let msg = req.get();
        println!("request: {:?}", msg);

        "hello world".to_string()
    };
    req.reply(reply).unwrap();
});

let response = channel.req(123).unwrap();
let reply = response.recv().unwrap();
println!("response: {:?}", reply);

License

MIT

No runtime deps