Dart Isolate.spawn无法同时传Uint8List与SendPort及消息接收失败问题

问题核心 #

Isolate.spawn确实只接受单个message参数，但这个参数可以是可序列化的复合对象（比如record、包含SendPort的列表），你之前用Isolate.current.controlPort的方式错误，因为这个端口是Isolate内部控制通道，并非用于自定义消息通信。

正确实现方式 #

直接用record把Uint8List和SendPort打包传递，子Isolate拿到后通过SendPort向主Isolate发送消息。

修正后的完整代码 #

import "dart:isolate";
import "dart:typed_data";

Future<void> main() async {
  final ReceivePort receivePort = ReceivePort();
  final Uint8List bytes = Uint8List(0);
  print("out.bytes.length: ${bytes.length}");

  // 用record打包bytes和receivePort.sendPort
  final Isolate isolate = await Isolate.spawn(
    (final (Uint8List, SendPort) args) {
      final (bytes, sendPort) = args;
      print("in.bytes.length: ${bytes.length}");
      // 通过传入的SendPort向主Isolate发消息
      sendPort.send(0);
      // 可选：发送完消息后关闭SendPort对应的ReceivePort（如果不需要继续通信）
      // Isolate.exit();
    },
    (bytes, receivePort.sendPort),
  );

  await receivePort
      .listen(
        (final Object? res) => print("out.receive_port.listen.result: $res"),
        onError: (final Object err, final StackTrace trace) =>
            print("out.receive_port.onError..err:\"$err\"..trace:\"$trace\""),
        onDone: () => print("out.receive_port.onDone"),
      )
      .asFuture<void>();

  print("out: KILL-ing isolate NOW");
  isolate.kill();
}

为什么之前的方法无效？ #

• Isolate.current.controlPort是Isolate的内部控制端口，用于接收系统级控制消息（比如终止信号），主Isolate的receivePort并没有监听这个端口，所以发送的消息无法被接收。
• 你之前尝试的列表方式如果没生效，可能是代码实现问题——列表只要包含可序列化对象（SendPort是可传输的）就可以正常传递，示例代码如下：

// 用列表传递的版本
final Isolate isolate = await Isolate.spawn(
  (final List<Object> args) {
    final Uint8List bytes = args[0] as Uint8List;
    final SendPort sendPort = args[1] as SendPort;
    print("in.bytes.length: ${bytes.length}");
    sendPort.send(0);
  },
  [bytes, receivePort.sendPort],
);

注意事项 #

• 传递给Isolate的对象必须是可序列化/可传输的：基本类型、Uint8List、SendPort、record、自定义类（如果是不可变的且无循环引用）都可以。
• 如果不需要子Isolate继续运行，发送完消息后可以调用Isolate.exit()替代手动kill，更优雅。

内容的提问来源于stack exchange，提问作者gitman-2021