Flutter Isolate处理超大JSON列表性能骤降问题排查与优化咨询

你的核心问题是在循环里为每个单独的元素创建Isolate——Isolate的启动、跨Isolate的数据序列化/反序列化都有不小的开销，10万次重复这个操作，性能不崩才怪。原来不使用Isolate时是单线程连续解析，没有额外开销；现在每处理一个元素都要走一遍Isolate的创建、传参、销毁流程，开销直接放大10万倍，自然进度慢到离谱。

优化步骤 #

1. 把整个解析任务一次性丢给单个Isolate #

不要循环创建Isolate，而是把整个article列表作为参数传给Isolate，在Isolate内部完成所有元素的解析，最后一次性返回结果。这样只需要创建一次Isolate，消除重复开销。

2. 移除Isolate内的UI操作 #

你在循环里调用LoadingOverlay.of(context).attachText(progress)，但Isolate不能访问主Isolate的上下文（context），而且频繁更新UI本身也会拖慢性能。如果需要显示进度，可以通过SendPort在Isolate里发送进度消息，主Isolate接收后更新UI。

3. 优化数据传递 #

尽量传递原始的JSON数据（比如整个List<dynamic>），避免在主Isolate里先做类型转换，减少跨Isolate的数据拷贝成本。

修改后的代码示例 #

Future<ServiceResponse> _createServiceResponse(Map<String, dynamic> map) async {
  Map<String, dynamic> responseMap = {};
  responseMap["assortment"] = AssortmentJson.fromJson(map).convertToObox().convertToDomain();

  if (map.containsKey("article")) {
    final articleList = map["article"] as List<dynamic>;
    // 创建通信端口，用于接收进度和结果
    final receivePort = ReceivePort();
    // 启动Isolate，传入原始列表和通信端口
    final isolate = await Isolate.spawn(
      _parseAllArticlesInIsolate,
      _IsolateParams(
        articleList: articleList,
        sendPort: receivePort.sendPort,
      ),
    );

    List<Article> articles = [];
    List<Ean> eans = [];
    int total = articleList.length;

    // 监听Isolate发来的消息
    await for (final message in receivePort) {
      if (message is _ProgressUpdate) {
        // 更新UI进度，每处理100条才更新一次，减少UI开销
        String progress = "${(message.count / total * 100).toInt()}%";
        LoadingOverlay.of(context).attachText(progress);
      } else if (message is _ParseResult) {
        articles = message.articles;
        eans = message.eans;
        break;
      }
    }

    // 关闭端口并销毁Isolate
    receivePort.close();
    isolate.kill();

    responseMap["articles"] = articles;
    responseMap["eans"] = eans;
  }

  return ServiceResponse(ok: true, payload: responseMap);
}

// Isolate参数类，必须可序列化，不能包含context等不可序列化对象
class _IsolateParams {
  final List<dynamic> articleList;
  final SendPort sendPort;

  _IsolateParams({required this.articleList, required this.sendPort});
}

// 进度更新消息类
class _ProgressUpdate {
  final int count;
  _ProgressUpdate(this.count);
}

// 解析结果消息类
class _ParseResult {
  final List<Article> articles;
  final List<Ean> eans;
  _ParseResult(this.articles, this.eans);
}

// Isolate内执行的解析函数，必须是静态或顶级函数
static void _parseAllArticlesInIsolate(_IsolateParams params) {
  List<Article> articles = [];
  List<Ean> eans = [];
  int counter = 0;

  for (var element in params.articleList) {
    final item = element as Map<String, dynamic>;
    final (article, eanList) = _createArticlesAndEanList(item);
    articles.add(article);
    eans.addAll(eanList);

    // 每处理100个元素发送一次进度，降低消息通信开销
    if (counter % 100 == 0) {
      params.sendPort.send(_ProgressUpdate(counter));
    }
    counter++;
  }

  // 发送最终解析结果
  params.sendPort.send(_ParseResult(articles, eans));
}

// 移除不必要的async，因为内部无异步操作，提升解析速度
static (Article, List<Ean>) _createArticlesAndEanList(Map<String, dynamic> articleJson) {
  List<Ean> eans = [];

  var article = ArticleJson.fromJson(
          articleJson.convertIdToInt().convertDateFormatToAppFormat())
      .convertToObox(assignReferences: false)
      .convertToDomain();

  Map<String, int?> propertyNotAssigned = {};
  if (articleJson.containsKey("ean")) {
    eans.addAll((articleJson["ean"] as List<dynamic>).map((e) =>
        EanJson.fromJson((e as Map<String, dynamic>).convertIdToInt())
            .convertToObox(
                assignReferences: false,
                propertyNameToId: propertyNotAssigned)
            .convertToDomain()
            .assignArticleFromArticleList(article)));
  }

  return (article, eans);
}

额外优化建议 #

• 如果JSON数据来自网络，尽量直接在Isolate里下载并解析，避免主Isolate接收大JSON数据后再传递到Isolate，减少一次数据拷贝。
• 可以用Flutter封装的compute函数替代手动创建Isolate，逻辑更简洁，本质和上述代码一致。
• 减少跨Isolate传递的对象复杂度，尽量用原始数据类型，避免传递复杂自定义对象，降低序列化/反序列化耗时。

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