Question: using async-scoped with for_each_concurrent about async-scoped

[rmanoka]

The signature of the "map" function in [for_each_concurrent] is F: FnMut<...>. This implies that the "map" function is never executed parallely. The futures in the stream are awaited concurrently, but not in parallel (the poll method is never run simultaneously in multiple CPU cores). Essentially, I/O, signals, etc. are awaited concurrently across the futures.

For parallelism, I've typically used rayon for CPU heavy algorithm parallelization. Another option is to use the spawn function of the executor (tokio/async-std/...), to spawn separate futures that are then run parallelly. Then, we simply await their join-results concurrently. In this case, the F is essentially no-op, so it's okay to not schedule it in parallel. Now, spawn expects 'static future, so this crate provides an ergo. API to spawn local futures (not 'static).

[rmanoka]

Closing as resolved.