34｜并发处理（下）：从atomics到Channel，Rust都提供了什么工具？

请问一下，目前rust的标准库中并没有类似concurrent hash map等并发安全的集合，虽然第三方库有一些实现，但是不容易从中做出选择，请问老师有什么推荐吗

Channel 把锁封装在了队列写入和读取的小块区域内，然后把读者和写者完全分离，使得读者读取数据和写者写入数据，对开发者而言，除了潜在的上下文切换外，完全和锁无关，就像访问一个本地队列一样 这段文字，我还是没有很明白，所谓对于channel和mutex锁的区别，是不是可以这样理解？channel可以看成是一个队列(vec那样的)，然后channel这里就是一头写入一头消费，那么如果有并发的时候，就是对头尾进行加锁，并且会做多一些其他的辅助操作，例如队列满了或者空的时候各种安全检查判断等等，实际上channel就是对mutex+queue的抽象封装？ 多谢了

go经常会使用 chan struct 来作为actor对象的退出信号，rust有什么建议不？不想和数据channel混合在一起。

读完本节有一个感悟，actor model是异步任务级别的“微服务”：发送信息给一个actor，然后从actor再接收信息，就类似于后端中发送一个请求给一个微服务，再接收响应。也就是说，一个actor对应一个“”微服务“”，不知道这种理解是否正确？还有就是，一个actor对应的是类似于tokio的一个task吗？

对，合理的使用 Channel，不应该死搬硬套。

笨拙地用 Channel 叠加 Channel 来应对所有的场景?Go: 你直接说我名儿得了。

工作线程中，缺了drop(started)，导致主线程无法获取mutex

老师，代码示例有点少啊，比如Channel这块，你的文字描述我都看懂了，但是没有使用Channel的代码示例，可能怎么调用我都不知道

#[test] fn test_mpsc() { let (a2btx, a2brx) = mpsc::channel(); let (b2atx, b2arx) = mpsc::channel(); let threada = thread::spawn(move || { a2btx.send("hello world!".to_string()).unwrap(); for re in b2arx { println!("{}\n", re); thread::sleep(Duration::from_secs(1)); a2btx.send("hello world!".to_string()).unwrap(); } }); let threadb = thread::spawn(move || { for re in a2brx { println!("{}\n", re); thread::sleep(Duration::from_secs(1)); b2atx.send("goodbye!".to_string()).unwrap(); } }); thread::sleep(Duration::from_secs(10)); return }

Mutex使用lock方法生成Guard锁住数据，而Guard通过drop方法才能把数据解锁。老师的例子化用了doc中的例子，但因为没有对变量 started 显式使用drop方法，而使用loop阻塞了 started 自动调用drop，所以和预设的结果表现不同。