Search results
线程间的消息传递. 在多线程间有多种方式可以共享、传递数据，最常用的方式就是通过消息传递或者将锁和 Arc 联合使用，而对于前者，在编程界还有一个大名鼎鼎的 Actor线程模型 为其背书，典型的有 Erlang 语言，还有 Go 语言中很经典的一句话：. Do not communicate ...
消息传递. 之前章节我们提到可以创建一个专门的任务 C1 (消费者 Consumer) 和通过消息传递来管理共享的资源，这里的共享资源就是 client 。. 若任务 P1 (生产者 Producer) 想要发出 Redis 请求，首先需要发送信息给 C1，然后 C1 会发出请求给服务器，在获取到结果后，再 ...
select! 在实际使用时，一个重要的场景就是同时等待多个异步操作的结果，并且对其结果进行进一步处理，在本章节，我们来看看，强大的 select! 是如何帮助咱们更好的控制多个异步操作并发执行的。 tokio::select! select! 允许同时等待多个计算操作，然后当其中一个操作完成时就退出等待:
标准库里的 mpsc（多生产者单消费者） 通道自从 1.0 版本就有了，这次版本更新将其实现修改成了基于 crossbeam-channel。 不涉及到API的变更，但是修改了一些已有的bug，提升了性能和代码可维护性。
Send 和 Sync. Send 和 Sync 是 Rust 安全并发的重中之重，但是实际上它们只是标记特征 (marker trait，该特征未定义任何行为，因此非常适合用于标记), 来看看它们的作用：. 实现 Send 的类型可以在线程间安全的传递其所有权. 实现 Sync 的类型可以在线程间安全的共享 ...
优雅关闭和资源清理 之前的程序，如果使用 ctrl-c 的方法来关闭，所有的线程都会立即停止，这会造成正在请求的用户感知到一个明显的错误。 因此我们需要添加一些优雅关闭 ( Graceful Shutdown )，以更好的完成资源清理等收尾工作。 为线程池实现 Drop 当线程池被 drop 时，需要等待所有的子线程完成它们的工作，然后再退出，下面是一个初步尝试:
异步跟同步共存. 一些异步程序例如 tokio 指南 章节中的绝大多数例子，它们整个程序都是异步的，包括程序入口 main 函数：. #[tokio::main] async fn main () {. println! ("Hello world"); } 在一些场景中，你可能只想在异步程序中运行一小部分同步代码，这种需求可以考虑下 ...
线程间传递消息导致主线程无法结束 本篇陷阱较短，主要解决新手在多线程间传递消息时可能会遇到的一个问题：主线程会一直阻塞，无法结束。 Rust 标准库中提供了一个消息通道，非常好用，也相当简单明了，但是但是在使用起来还是可能存在坑：
线程同步：Atomic 原子类型与内存顺序. Mutex 用起来简单，但是无法并发读， RwLock 可以并发读，但是使用场景较为受限且性能不够，那么有没有一种全能性选手呢？. 欢迎我们的 Atomic 闪亮登场。. 从 Rust1.34 版本后，就正式支持原子类型。. 原子指的是一系列不可 ...
看起来，还需要添加一个库包，未来线程池的代码都将在这个独立的包中完成，甚至于未来你要实现其它的服务，也可以复用这个多线程库包。. 创建 src/lib.rs 文件并写入如下代码: #! [allow (unused)] fn main () { pub struct ThreadPool; } 接着在 main.rs 中引入: #! [allow (unused ...
