#线程安全 #队列 #执行 #速度 #异步 #acter

已删除 acter_queue

快速速度线程安全异步执行队列

0.1.0 2020年11月17日

#116 in #速度

MIT/Apache

7KB
120

快速速度线程安全异步执行队列

#示例

use acter_queue::AQueue;
static mut VALUE:i32=0;

#[tokio::main]
async fn main()->Result<(),Box<dyn Error+Sync+Send>> {
    let queue = AQueue::new();
    let mut v=0i32;
    for i in 0..2000000 {
        v= queue.run(async move |x| unsafe {
            // thread safe execute
            VALUE += x;
            Ok(VALUE)
        }, i).await?;
    }

    assert_eq!(v,-1455759936);
   
}

依赖项

~4MB
~66K SLoC