Flutter 简化线程Isolate的使用

文章目录

前言
一、完整代码
二、使用示例
- 1、通过lambda启动线程
- 2、获取线程返回值
- 3、线程通信
- 4、结束isolate
总结

前言

flutter的线程是数据独立的，每个线程一般通过sendport来传输数据，这样使得线程调用没那么方便，本文将提供一种支持lambda启动isolate的方法，且支持捕获值类型变量，以及支持返回值。

一、完整代码

由于代码量较少，原理就不介绍了，直接给出完整实现。
isolate_helper.dart

///在隔离中执行任务，只能捕获值，不能捕获引用或指针。
///需要注意成员方法中调用传lambda会自动捕获this，this中包含引用类型则不行，此时可修改为static方法中调用。
Future<T> isolateFuture<T>(T Function() isolateEntry) async {ReceivePort receivePort = ReceivePort();//创建一个Isolate相当于创建一个子线程await Isolate.spawn((message) {message.sendPort.send(message.isolateEntry());}, _IsolateMessage(isolateEntry, receivePort.sendPort));var ret = await receivePort.first as T;return ret;
}class _IsolateMessage<T> {T Function() isolateEntry;SendPort sendPort;_IsolateMessage(this.isolateEntry, this.sendPort);
}

二、使用示例

1、通过lambda启动线程

void test() {String a = "hello word!";isolateFuture(() {//在子线程中执行任务，捕获（拷贝）了变量a。print("${Isolate.current.hashCode} $a");});print("${Isolate.current.hashCode} $a");
}

在这里插入图片描述

2、获取线程返回值

Future test1() async {String a = await isolateFuture(() {//在子线程中执行任务：略//返回结果return "hello word!";});print(a);
}

在这里插入图片描述

3、线程通信

void test2() {ReceivePort mainReceivePort = ReceivePort();SendPort isolateSendPort;mainReceivePort.listen((message) {//监听子线程的消息switch (message[0]) {case 0:print(message[1]);break;case 1:isolateSendPort = message[1];isolateSendPort.send([0, "hello word!"]);break;}});//sendport是可以直接捕获传给isolate的。final mainSendPort = mainReceivePort.sendPort;isolateFuture(() {//发送消息给主线程mainSendPort.send([0, "hello word!"]);ReceivePort isolateReceivePort = ReceivePort();isolateReceivePort.listen((message) {//监听主线程的消息switch (message[0]) {case 0:print(message[1]);break;}});//将sendPort发送到主线程，建立双向通信mainSendPort.send([1, isolateReceivePort.sendPort]);});
}

在这里插入图片描述

4、结束isolate

Future test1() async {String a = await isolateFuture(() {//isolate结束时建议手动kill，即此方法返回后isolate并不会结束，所以支持异步操作。返回后没有任何操作了gc似乎会清理isolate。Isolate.current.kill();return "hello word!";});print(a);
}