代码之家 › 专栏 › 技术社区 › sdgfsdh

我该怎么说。使用异步转换函数进行收集?

async-await f#

sdgfsdh · 技术社区 · 6 年前

假设我有两个 async 功能:

fetchCategories 获取产品类别的列表( string List )
fetchProductsForCategory 获取给定类别的产品列表( 字符串列表 )

我想写一个函数 fetchProducts 获取所有类别的所有产品。结果应该是一个元组列表( string * string List ).

然而,我不确定现在是否适合 异步的 和 Seq.collect 在一起

以下是我的尝试,希望能让我的意图更加清晰:

let fetchProducts () = async {
  let! categories = fetchCategories ()
  return categories
    |> Seq.collect (fun c -> async {
      let! products = fetchProductsForCategory c
      return products
        |> Seq.map fun p -> (c, p)
    })
    |> Seq.toList
}

1 回复 | 直到 6 年前

Fyodor Soikin 6 年前

实现你所追求的目标最直接的方法就是简单地运行所有 fetchProductsForCategory 一个接一个地,然后连接他们的结果。要在运行下一个执行之前等待上一个执行完成,请使用 Async.RunSynchronously :

let fetchProducts () = async {
  let! categories = fetchCategories ()
  return categories
    |> Seq.collect (fun c ->
      fetchProductsForCategory c 
        |> Async.RunSynchronously          
        |> Seq.map (fun p -> (c, p))
    )
    |> Seq.toList
}

(顺便说一句,请注意,您的代码不会生成 Seq<string * string list> 你说你期待,但是 Seq<string * string> -每种产品及其类别;但这不是重点)

然而,这种方法有一个明显的缺点,那就是浪费宝贵的时间。处决 获取产品类别 可以并行运行,从而获得更好的性能。

罗:有一个应用程序可以实现这一点。这个 Async.Parallel 函数接受一系列异步计算,并行运行它们,并将其结果作为数组返回:

let fetchProducts () = async {
  let! categories = fetchCategories ()
  let! products = categories 
                   |> Seq.map fetchProductsForCategory 
                   |> Async.Parallel

  Seq.zip categories products
}

推荐文章

Akshay Malvankar · 我对在asp中使用asyn、await()和run()方法感到困惑。净mvc[关闭]

2 年前

Sante Kyaku · 为什么我要用等待来获得承诺的结果?

2 年前

rockets4all · 文件getElementbyId未找到由提取添加的元素

2 年前

Tomas Kubes · 是最大并发数。NET任务有限吗?

2 年前

Grant Pitt · 在JavaScript中导出异步值的最佳实践是什么?

2 年前

punkish · 并行异步获取/等待承诺。全部的

2 年前

dapidmini · 未捕获的承诺嵌套异步函数承诺错误处理

2 年前

Deepak Dev · 如何在包含多个异步函数的foreach循环中返回数据

2 年前

smith · 如何在vue中使用wait/async

2 年前

Andres533 · 将参数传递给async/await函数将返回“undefined”

2 年前