我想从外部API获取数据:当只更改一个参数(页面)时,它是一个类似的请求。我想让它并行处理,但在一个地方收集数据。完成它的正确方法是什么……
Task.async_stream 可能适合您的需求。
(1..10) |> Task.async_stream(fn n -> get_page(n) end, max_concurrency: 10, timeout: 30_000, ordered: true) |> Stream.map(fn {:ok, data} -> data end) |> Enum.to_list()