Dart处理大量长耗时任务：单Isolate vs 多Isolate选型咨询

针对你的问题，我得先给个明确结论：绝对不要为每个任务单独创建Isolate——这会带来灾难性的性能开销，完全是舍本逐末的做法。

为什么不能每个任务开一个Isolate？ #

Dart的Isolate可不是轻量级线程，每个Isolate都有独立的内存堆、消息循环系统，创建和销毁它的成本相当高。如果要处理10000个任务，每个都开新Isolate，你的系统会被瞬间占满内存，上下文切换的开销也会让整体执行速度暴跌，甚至可能直接导致程序崩溃。

正确的做法：复用单个（或少量）Isolate #

就像你给出的代码那样，用一个Isolate来处理所有任务才是最优解——只承担一次Isolate创建的开销，后续所有任务都复用这个Isolate的执行环境，消息传递的开销和Isolate本身的资源占用都能降到最低。如果你的任务是CPU密集型，还可以进一步优化：根据你的CPU核心数创建一个小的Isolate池（比如4核就开4个），把任务分片分配给不同的Isolate，充分利用多核性能，比单个Isolate的处理速度更快。

对你现有实现的分析和优化建议 #

你的代码思路完全正确，通过SendPort和ReceivePort在主Isolate和工作Isolate之间传递消息，工作Isolate启动后先把自己的端口发给主Isolate，主Isolate就可以持续推送任务过去。这里有几个小优化点可以参考：

• 批量推送任务：比如一次发送100个任务而不是单个发送，减少消息传递的次数，降低消息队列的压力
• 添加任务完成回调：当前代码只是打印结果，实际场景中可以给input方法加回调，方便主Isolate处理每个任务的结果
• 异常处理：在工作Isolate的listen里添加错误处理，避免单个任务失败导致整个Isolate挂掉

下面是格式化后的完整代码：

单个Isolate处理任务的实现

import 'dart:isolate';

class DataPacket {
  SendPort port;
  int result;
}

class SquareRootCalculator {
  final ReceivePort _masterPort = ReceivePort();
  SendPort _workerPort;

  SquareRootCalculator() {
    Isolate.spawn(isolateFunction, _masterPort.sendPort).then((isolate) {
      _masterPort.listen((data) {
        if (_workerPort == null) {
          _workerPort = data.port;
        } else {
          print('任务结果：${data.result}');
        }
      });
    });
  }

  void input(int n) {
    _workerPort?.send(n);
  }
}

void isolateFunction(SendPort masterPort) {
  final ReceivePort _workerPort = ReceivePort();
  final DataPacket packet = DataPacket()
    ..port = _workerPort.sendPort
    ..result = -1;
  masterPort.send(packet);

  _workerPort.listen((data) {
    try {
      final int out = calculate(data);
      final DataPacket resultPacket = DataPacket()
        ..port = _workerPort.sendPort
        ..result = out;
      masterPort.send(resultPacket);
    } catch (e) {
      print('处理任务$data失败：$e');
    }
  });
}

int calculate(int number) {
  // 模拟长耗时CPU密集任务
  for (var i = 0; i < 1000000000; ++i) {}
  return number * number;
}

任务推送示例

void main() async {
  SquareRootCalculator _calc = SquareRootCalculator();
  for (int i = 0; i < 100; ++i) {
    _calc.input(i);
    await Future.delayed(const Duration(seconds: 1));
  }
}

内容的提问来源于stack exchange，提问作者Anil8753