当我尝试在隔离中使用流时，如果遇到类似问题，我会遇到一个奇怪的问题
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方法内添加了接收端口，即使我不使用接收端口，它也能正常工作
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;
}
}
本文收集自互联网，转载请注明来源。
如有侵权，请联系 [email protected] 删除。
我来说两句