来自 Rayon 的并行迭代器与 Rust 中来自 ureq 的阻止 HTTP 之间的交互是什么?
What is interaction between paralel iterators from Rayon and blocking HTTP from ureq in Rust?
如果我有一个包含 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
如果我有一个包含 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