Rayon 的并行迭代器与 Rust 中的 ureq 阻止 HTTP 之间的交互是什么?

问题描述

如果我有一个包含 100 个 url 的 vec 并制作并行迭代器来生成 100 个阻塞 HTTP 请求,那么第一个请求会阻塞其余的请求,还是可以在其中一些完成之前完成所有请求?

解决方法

当您调用 Rayon 方法时,它会创建一个 ThreadPool。您可以使用要并行运行的线程数创建自己的 ThreadPool

因此在您的特定情况下,每个请求都会阻塞它在其中执行的线程,但线程将并行运行。换句话说,如果您有 3 个线程的池,那么它将并行执行 3 个请求。

Vec: [#1,#2,#3,#4,#5,#6,#7,#8] // list of requests
time ->

thread 1: #1...#4......#8
thread 2: #2.....#6...#7
thread 3: #3....#5