asynchronous - 从 OCaml/Async 中的延迟列表中获取任何非错误元素

Question

假设我有一个功能，例如:

query_server : Server.t -> string Or_error.t Deferred.t

然后我生成一个延迟查询列表:

let queries : string Or_error.t Deferred.t list = List.map servers ~f:query_server

如何获得不失败的第一个查询的结果(或其他错误)。基本上，我想要一个功能，例如:

any_non_error :  'a Or_error.t Deferred.t list -> 'a Or_error.t

另外，我不确定如何以某种方式汇总错误。也许我的函数需要一个额外的参数，例如 Error.t -> Error.t -> Error.t还是有一种标准的方法来组合错误？

Answer 1

一个简单的方法是使用 Deferred.List它包含提升到 Async monad 中的列表操作，基本上是 Kleisli 类别中的容器接口(interface)。我们将按顺序尝试每个服务器，直到第一个服务器准备好，例如，

let first_non_error = 
  Deferred.List.find ~f:(fun s -> query_server s >>| Result.is_ok)

当然不是any_non_error ，因为处理是顺序的。此外，我们正在丢失错误信息(尽管后者很容易修复)。

因此，为了使其并行，我们将采用以下策略。我们将有两个延迟计算，第一个将并行运行所有查询并等待一切就绪，第二个将在收到 Ok 结果后立即确定。如果第一个发生在最后一个之前，则意味着所有服务器都失败了。所以让我们试试:

 let query_servers servers = 
   let a_success,got_success = Pipe.create () in
   let all_errors = Deferred.List.map ~how:`Parallel servers ~f:(fun s -> 
      query_server s >>| function
      | Error err as e -> e
      | Ok x as ok -> Pipe.write_without_pushback x; ok) in
   Deferred.any [
       Deferred.any all_errors;
       Pipe.read a_success >>= function
       | `Ok x -> Ok x
       | `Eof -> assert false
   ]