【Flutter】多线程

Flutter 作为一个跨平台的UI库，前面的Flutter 架构有涉及到，Flutter 架构中的运行的多个线程。那么最为一个Flutter开发者，我们如何创建线程呢

多线程

上述我们提及到了，架构层涉及的多线程问题。比如说 主线程, 平台线程，GPU线程。本文讨论的及主线程，dart 运行在虚拟中的多线程问题。OK，言归正传。

线程模型

作为一个iOSer，我们在移动端开发的时候，会有多线程的应用场景。关于iOS中多线程我们会遇到线程同步的问题。比如说资源竞争，数据同步我们会引用到锁, 关于自旋，互斥的面试问题也是考察比较多的。呢么flutter 的线程模型是啥呢。这里我们引入isolate

Isolate

flutter的线程是一个独立的Isolate, 每个Isolate 管理其属于自己的EventLoop (此处的设计思路和iOS中线程与RunLoop的关系是一样的)和JS的事件循环蕾丝，关于EventLoop事件循环后续会出文章解释，此处不提及。需要注意的是async 在没有创建新的Isolate时，还是会将事件推入主Isolate 的任务队列当中的。

Talk is cheap

言归正传，了解了flutter 中的线程模型。那我们如何创建新的Isolate。举个🌰，我们需要从文件中读取配置。在处理I/O费时操作的时候，我们一般会创建一个新的Isolate

dart Isolate 🌰

import 'dart:convert';
import 'dart:io';
import 'dart:isolate';

void main(List<String> args) async {
  print("${Isolate.current.debugName}");
  final jsonData = await Isolate.run(_readAndParseJson);
}

Future<Map<String, dynamic>> _readAndParseJson() async {
  final configuration = await File("configuration.json").readAsString();
  final jsonData = jsonDecode(configuration) as Map<String, dynamic>;
  print("${Isolate.current.debugName}");
  return jsonData;
}

输出结果如下

main
_RemoteRunner._remoteExecute

Exited.

flutter🌰

import 'dart:convert';
import 'dart:io';
import 'dart:isolate';

import 'package:flutter/foundation.dart';
import 'package:flutter/material.dart';
import 'package:flutter/services.dart';

void main() {
  runApp(const MainApp());
}

class MainApp extends StatefulWidget {
  const MainApp({super.key});

  @override
  State<MainApp> createState() => _MainAppState();
}

class _MainAppState extends State<MainApp> {
  String content = "内容占位符";

  void _updateContent() async {
    // Map<String, dynamic> configuration = await _readAndParseJson();
    print("${Isolate.current.debugName}");
    Map<String, dynamic> configuration = await _readAndParseJson();
    final name = configuration["name"];
    setState(() {
      content = name;
    });
  }

  @override
  Widget build(BuildContext context) {
    return MaterialApp(
      home: Scaffold(
        appBar: AppBar(
          title: const Text("jeverson's eg"),
        ),
        body: Center(
            child: Text(
          content,
          style: const TextStyle(color: Colors.black),
        )),
        floatingActionButton: FloatingActionButton(
          onPressed: _updateContent,
          child: const Icon(Icons.update),
        ),
      ),
    );
  }
}

Future<Map<String, dynamic>> _readAndParseJson() async {
  final configuration = await rootBundle.loadString("lib/configuration.json");
  return compute((message) {
    print("${Isolate.current.debugName}");
    return jsonDecode(configuration) as Map<String, dynamic>;
  }, configuration);
}

ByTheWay

演示代码中我们使用的是dart，使用的是run, 在flutter 中我们使用compute 函数。

TODOIsolate间通信