Crate crossfire

source ·
Expand description


This crate provide channels used between async-async or async-blocking code, in all direction. Implmented with lockless in mind, low level is based on crossbeam-channel


Faster than channel in std or mpsc in tokio, slightly slower than crossbeam itself (since async overhead to wakeup sender or receiver).



Add this to your Cargo.toml:

crossfire = "0.1"
tokio = "0.2"

extern crate crossfire;
extern crate tokio;
use crossfire::mpsc;

// async-async

let rt = tokio::runtime::Builder::new_multi_thread().enable_all().build().unwrap();

let (tx, rx) = mpsc::bounded_future_both::<i32>(100);

rt.block_on(async move {
   tokio::spawn(async move {
       for i in 0i32..10000 {
           let _ = tx.send(i).await;
           println!("sent {}", i);

   loop {
       if let Ok(_i) = rx.recv().await {
           println!("recv {}", _i);
       } else {
           println!("rx closed");

mpmc & mpsc package is almost the same, while mpsc has some optimization becauses it assumes only one consumer.

Error types are re-exported from crossbeam-channel.


Supports stable Rust. Mainly tested on tokio-0.2 (Not tried on async-std or other runtime). future::selects and timeout work fine, but it takes advantage of runtime behavior not documented by Rust official.

Refer to

Memory overhead

While using mp tx or mp rx, there’s memory overhead to pass along wakers for pending async producer or consumer. Since waker is small, the overhead can be ignored if your channel is busy. Canceled wakers will be eventually cleanup by later send/receive event. If the channel is used for close notification (which never trigger) in combine with futures::select, currently there’s hard coded threshold to clean up those canceled wakers.