smallnest / concurrency-programming-via-rust

Hello, I'm 鸟窝 👋

大道至简，简即是繁

• 个人网站: https://colobu.com
• 最好的Go微服务框架: https://rpcx.io
• rpcx官方博客: https://blog.rpcx.io

concurrency-programming-via-rust's Issues

ch01 Thread.pdf error

应该是 “认为” ？

error: no matching package named `atomic_mpmc` found

error: the crate atomic_mpmc could not be found in registry index

threadpool_executor

44页

1. 线程池构建器

ThreadPool::builder()
        .core_threads(4)
        .max_threads(8)
        .keep_alive(Duration::from_secs(30))
        .build();

=>

threadpool::Builder::new()
        .core_pool_size(4)
        .maximum_pool_size(8)
        .keep_alive_time(Duration::from_secs(30))
        .build();

2. 支持不同的任务提交方式

pool.execute(async {
        // ...
});

应该不支持

45页

let result = pool.execute(|| {
 Ok(1 + 2)
 })?;

 let res = result.unwrap().get_result_timeout(std::time::Duration::from_secs(3))
;
 assert!(res.is_err());
 if let Err(err) = res {
 matches!(err.kind(), threadpool_executor::error::ErrorKind::TimeOut);
 }

=>

    let mut result: threadpool_executor::Expectation<Result<i32, ()>> = pool
        .execute(|| {
            thread::sleep(Duration::from_secs(5));
            Ok(1 + 2)
        })
        .unwrap();

    let res = result.get_result_timeout(Duration::from_secs(3));

    assert!(res.is_err());

    if let Err(e) = res {
        assert!(matches!(
            e.kind(),
            threadpool_executor::error::ErrorKind::TimeOut
        ));
    }

poolite builder

第40页
可以通过 Builder 自定义线程数:
let pool = poolite::Pool::builder().thread_num(8).build()?;
貌似没有builder这个方法
是不是应该
poolite::Builder::new().max(8).build()?

channel章节运行锁中毒-pub fn async_priority_channel_example()

note: Some details are omitted, run with RUST_BACKTRACE=full for a verbose backtrace.
thread 'main' panicked at 'task panicked while holding lock: PoisonError { .. }'...

English version of this book ?

First of all, thank you very much for your impressive effort. Do you have any plans for releasing English version of this book ?
Thanks

scc有效版本为1.4.4

special章节改成这样能编译成功
scc = "1.4.4"

Have a website for it?

Is there an online site where you can read it? Like the book "Rust High Performance Programming Guide"?tks!

executor_service

42页

支持闭包、Future 等任务形式:
pool.spawn(async {});

spawn方法应该没有

43页
4. 提供方便的线程池构建器
ThreadPoolExecutor应该没有 像是把threadpool_executor库的写错到这里了

atomic_mpmc作者删库跑路了

改成这样能编译成功
atomic_mpmc = {git="https://github.com/DexterHaxxor/atomic_mpmc",version="0.2.0"}