如何在 Dart 中使用 Isolate 实现子线程与主线程通信？

Question

Isolate相关的问题

最近在学flutter,所以刚接触了dart,遇到了一个关于isolate的问题：
我想实现一个简单的案例，子线程给主线程发送一些数据（包含'hello'字符串），当主线程收到'hello'会给子线程回复'hi'，由于想直观的看到运行结果我加了sleep。但是实际的运行结果并没有如我想象的一样，代码如下：

void main(){
  var rece = new ReceivePort();
  Isolate.spawn((sendPort) {
    var sonRece = new ReceivePort();
    sendPort.send(sonRece.sendPort);
    sonRece.listen((message) {
      print("子线程收到信息：$message");
    });

    for (var i = 0; i < 10; i++) {
      sleep(Duration(seconds: 2));
      if (i == 6) {
        sendPort.send("hello");
        continue;
      }
      sendPort.send(i);
    }
  }, rece.sendPort);

  //主线程监听
  rece.listen((message) {
    var sendPort;
    if (message is SendPort) {
      sendPort = message;
    }
    print("主线程收到信息：$message");
    if (message == "hello") {
      sendPort?.send("hi");
    }
  });
}

运行结果：

代码运行结果为什么没有打印'子线程收到信息：hi'呢？

Answer 1

把SendPort 放外面：

void main() {
  var rece = new ReceivePort();
  SendPort? childSendPort; 
  
  Isolate.spawn((sendPort) {
    var sonRece = new ReceivePort();
    sendPort.send(sonRece.sendPort);
    
    sonRece.listen((message) {
      print("子线程收到信息：$message");
    });

    for (var i = 0; i < 10; i++) {
      sleep(Duration(seconds: 2));
      if (i == 6) {
        sendPort.send("hello");
        continue;
      }
      sendPort.send(i);
    }
  }, rece.sendPort);

  rece.listen((message) {
    if (message is SendPort) {
      childSendPort = message; 
    } else {
      print("主线程收到信息：$message");
      if (message == "hello") {
        childSendPort?.send("hi"); 
      }
    }
  });
}

建议用异步代替 sleep，这样更不会堵：

void main() {
  var rece = new ReceivePort();
  SendPort? childSendPort;
  
  Isolate.spawn((sendPort) async {
    var sonRece = new ReceivePort();
    sendPort.send(sonRece.sendPort);
    
    sonRece.listen((message) {
      print("子线程收到信息：$message");
    });

    for (var i = 0; i < 10; i++) {
      await Future.delayed(Duration(seconds: 2));
      if (i == 6) {
        sendPort.send("hello");
        continue;
      }
      sendPort.send(i);
    }
  }, rece.sendPort);

  rece.listen((message) {
    if (message is SendPort) {
      childSendPort = message;
    } else {
      print("主线程收到信息：$message");
      if (message == "hello") {
        childSendPort?.send("hi");
      }
    }
  });
}

Answer 2

可以通过将sendPort声明在外部作用域来解决

主线程收到信息：SendPort
主线程收到信息：0
主线程收到信息：1
主线程收到信息：2
主线程收到信息：3
主线程收到信息：4
主线程收到信息：5
主线程收到信息：hello
子线程收到信息：hi
主线程收到信息：7
主线程收到信息：8
主线程收到信息：9

import 'dart:isolate';
import 'dart:async';

void main() {
  var mainReceivePort = ReceivePort();
  Isolate.spawn(isolateEntry, mainReceivePort.sendPort);

  SendPort? isolateSendPort;

  mainReceivePort.listen((message) {
    if (message is SendPort) {
      isolateSendPort = message;
    } else {
      print("主线程收到信息：$message");
      if (message == "hello") {
        isolateSendPort?.send("hi");
      }
    }
  });
}

void isolateEntry(SendPort mainSendPort) async {
  var isolateReceivePort = ReceivePort();
  mainSendPort.send(isolateReceivePort.sendPort);

  isolateReceivePort.listen((message) {
    print("子线程收到信息：$message");
  });

  for (var i = 0; i < 10; i++) {
    await Future.delayed(Duration(seconds: 2));
    if (i == 6) {
      mainSendPort.send("hello");
      await Future.delayed(Duration(milliseconds: 100)); // 确保 "hi" 在 "hello" 之后发送
    } else {
      mainSendPort.send(i);
    }
  }
}