dart - 为什么 Dart 隔离中的流在没有接收端口的情况下不起作用
问题描述
当我尝试在隔离内使用流时,我遇到了一个奇怪的问题,如果我尝试这样的事情
main() async {
await Isolate.spawn(entryPoint, null);
}
entryPoint(SendPort sendPort) {
getStreamOfNumbers().listen((data) => print('data : $data'));
}
Stream<int> getStreamOfNumbers() async* {
for (int x = 0; x < 10; x++) yield x;
}
控制台没有打印任何内容,但是如果我在主方法中添加一个接收端口,它工作正常,即使我不使用接收端口
main() async {
ReceivePort receivePort = ReceivePort();
await Isolate.spawn(entryPoint, null);
}
//the output is :
//data : 0
//data : 1
//data : 2
//data : 3
//data : 4
//data : 5
//data : 6
//data : 7
//data : 8
//data : 9
这是一个错误还是我有什么问题?
解决方案
第一个示例中的问题是您没有等待在主线程/隔离中完成隔离。当主线程/隔离没有任何事情可做并且事件队列为空时,Dart 退出。
在您的下一个示例中,它“有效”,但您没有说的是程序永远不会退出。那是因为您创建了一个没有侦听器的 ReceivePort,这会阻止主线程/隔离停止,因为它现在永远等待。
如果您改为以这种方式使用 ReceivePort,则可以使用它来等待隔离完成,并且仅在发生这种情况时退出主循环:
import 'dart:isolate';
Future<void> main() async {
final rPort = ReceivePort();
await Isolate.spawn(entryPoint, null, onExit: rPort.sendPort);
await rPort.first;
}
void entryPoint(SendPort sendPort) {
getStreamOfNumbers().listen((data) => print('data : $data'));
}
Stream<int> getStreamOfNumbers() async* {
for (var x = 0; x < 10; x++) {
yield x;
}
}
推荐阅读
- mysql - 无法读取未定义的属性“json”
- python - 收件人姓名和所需的与会者与 Outlook Python 不匹配
- javascript - 如何在 x 轴上仅显示工作日?
- python - Python 3 重启:
- python - 为什么我的日期没有正确排序?
- spring-boot - SpringBoot + Rabbitmq - DLQ 队列不起作用
- javascript - RESTful 路由 - 无法获取我的“新”路由来发布(JavaScript、Node、Mongoose)
- python - 如何从另一个字典中减去一个字典的值并将结果写入第三个?
- python - Discord.py D&D 掷骰子命令有太多问题
- slack - 在键入时使用降价样式时,Slack 会自动格式化消息