撰寫Task.async_stream與延續傳遞

Question

我有兩個函數的管道，這兩個函數都是重IO，並行運行在一組項目上。

第一個，func1很常見，而且我經常只想要func1的響應。其他時候，我想用其他函數func2來處理func1的結果。

什麼是構成Task.async_stream之間的權衡（性能/開銷，地道的煩躁），即

enum 
|> Task.async_stream(Mod1, :func1, []) 
|> Task.async_stream(Mod2, :func2, []) 
... 

與傳遞一個延續，並使用一個Task.async_stream兩個func1和func2即

enum 
|> Task.async_stream(Mod1, :func1_then, [&Mod2.func2/arity]) 
... 

其中func1_then調用以正常func1計算結束的功能參數（Mod2.func2）？

Answer 1

如果這兩個功能IO約束，那麼不應該有你的第一個例子中的任何問題：

enum 
|> Task.async_stream(Mod1, :func1, []) 
|> Task.async_stream(Mod2, :func2, []) 

如果你沒有要摺疊的兩個電話，我不會用一個延續的風格，只是他們的管道中拉姆達傳遞給Task.async_stream/3：

enum 
|> Task.async_stream(fn x -> x |> Mod1.func1() |> M2.func2() end) 

或者，你可以考慮使用Flow：

enum 
|> Flow.from_enumerable() 
|> Flow.map(&Mod1.func1/1) 
|> Flow.map(&Mod2.func2/1) 
|> Flow.run()