dart - 将重复发送/响应封装到单个异步函数中的同一 Dart 隔离中

Question

是否可以将重复的发送/响应封装到单个异步函数中的同一个 dart 隔离中？

背景:

为了设计一个方便的API，我希望有一个函数异步返回隔离生成的结果，例如

var ans = await askIsolate(isolateArgs);

如果我直接使用 spawnUri 调用生成的响应，则效果很好，例如

Future<String> askIsolate(Map<String,dynamic> isolateArgs) {

ReceivePort response = new ReceivePort();
var uri = Uri.parse(ISOLATE_URI);

Future<Isolate> remote = Isolate.spawnUri(uri, [JSON.encode(isolateArgs)], response.sendPort);
return remote.then((i) => response.first)
               .catchError((e) { print("Failed to spawn isolate"); })
               .then((msg) => msg.toString());
}

然而，上述方法的缺点是，如果我需要重复调​​用askIsolate，则每次都必须生成隔离。

我想与正在运行的isolate进行通信，这当然可以通过让isolate向调用者返回sendPort来实现。但我相信自从 2013 Isolate refactoring ，这需要调用者监听 receivePort 上的后续消息，从而无法封装在单个异步函数中。

是否有某种机制可以实现我所缺少的功能？

Answer 1

答案取决于您打算如何使用隔离

• 您打算让它无限期地运行，向其发送输入并期望异步接收答案吗？

• 您是否想一次发送隔离许多(但有限)输入，期望异步接收答案，然后关闭隔离？

我猜是后者，并且您的 askIsolate() 函数需要立即返回一个 Future，而不是在收到所有答案时完成。

await for 循环可用于监听流并消耗事件，直到其关闭。

我对分离株不熟悉，所以我希望这没问题，我还没有测试过。我假设隔离终止并且响应关闭。

String askIsolate(Map<String,dynamic> isolateArgs) async {

  ReceivePort response = new ReceivePort();
  var uri = Uri.parse(ISOLATE_URI);

  Isolate.spawnUri(uri, [JSON.encode(isolateArgs)], response.sendPort)
    .catchError((e)) {
     throw ...;
   });

  List<String> answers = new List<String>;

  await for(var answer in response) {
    out.add(answer.toString());
  }

  return answers;
}

注意:

• response 是您正在收听以获取答案的流。它是在生成隔离之前创建的，因此您不需要(也可能不应该)等待隔离 future 完成后再收听它。

• 我将 askIsolate() 设为异步，因为这样可以很容易地立即返回一个 future，该 future 在函数返回时完成 - 无需使用 .then( ...) 链，我个人觉得它令人困惑且难以阅读。

顺便说一句，您原来的 then(...).catchError(...) 样式代码最好像这样编写:

  Isolate.spawnUri(uri, [JSON.encode(isolateArgs)], response.sendPort)
    .catchError((e) { ... });

   return response.first)
     .then((msg) => msg.toString());

我相信，在创建隔离之后延迟将 catchError 处理程序附加到行可能会导致 future 在处理程序就位之前完成并出现错误。

参见:https://www.dartlang.org/articles/futures-and-error-handling/#potential-problem-failing-to-register-error-handlers-early .