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
12KB
182 lines
mrsc
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