首先声明Dart是单线程语言，也就是说它没有像OC、Swift 那样复杂的多线程控制。
也就可以理解为 Dart只有一个主线程，没有其他线程。
Future、scheduleMicrotask（微任务）、Isolate、Compute
Even Loop
Flutter 的 loop 优先级讲解 主线程任务优先执行 > scheduleMicrotask（微任务）（其他微任务）> Future -->当前Future的then等回调 > 其他Future --> 其他Future
Isolate、compute
严格来讲 Isolate、compute（对Isolate的封装）是正经的多线程，和iOS 多线程一样,这是Dart给我们提供的一个多线程的一个接口。
Future
void getData() async {
print('开始data=$_data');
// 后面的操作 必须是异步才能用 await 修饰
// 当前函数必须是 异步函数 才能用 await 修饰
// await Future((){
//
// for (int i = 0; i < 10000000; i++) {
// _data = '好事';
//
// }
//
// });
// print('介绍data=$_data');
// 如果不想用 await 阻塞当前线程 可以用 回调方式 。
Future future = Future((){
for (int i = 0; i < 10000000; i++) {
_data = '好事';
// return '网络数据';
// 如果出现异常 可以
return throw Exception('网络异常');
}
});
// 使用 then 这个函数来接收回调
// future.then((value) => print(value));
// print('在干点其他事情');
// future.catchError((error){
// print('捕获到了${error.toString()}');
// });
// 根据上面 我们可以这么写 先捕获异常 再捕获 回调
// 这样 仍然会 走 then 但是不会抛错
future.catchError((error){
print(error);
}).then((value) => print(value)).whenComplete(() => print('完成'));;
// 如果不想走 then
future.then((value){print('object');}, onError: (error){}).whenComplete(() => print('完成'));
// 是不是 和 Rx 一毛一样 没什么学习成本
}
通过这个方法就可以看到 Flutter 的优先级相同异步任务 和 原生的 区别 ， 他会按顺序执行异步任务，这也可以理解Flutter只会有一个主线程不会有任何其他线程。
void textFuture() {
Future((){sleep(Duration( seconds: 2)); return '任务1';}).then((value) => print('$value结束'));
Future((){return '任务2';}).then((value) => print('$value结束'));
Future((){return '任务3';}).then((value) => print('$value结束'));
Future((){return '任务4';}).then((value) => print('$value结束'));
/// iOS 线程间依赖 --- Flutter 任务依赖
///
///
Future((){
return '依赖的前置条件任务 5 ';
}).then((value) {
print('$value完成');
return '执行条件语句任务 6';
}).then((value) {
print('$value完成');
// return '执行接下来的语句';
}).then((value) {
print(value == null ? '未抛出任何数据' : value) ;
return value == null ? throw Exception('异常') : value;
} ).catchError((error) => print(error)).whenComplete(() => '所有任务complete');
}
Future 的编程组 DispatchGroup
Future.wait Future.wait([异步1, 异步2])
void textFuture2(){
Future.wait([Future((){
return '任务1';
}),
Future((){
return '任务2';
}),]).then((value) => print(value[0] + value[1]));
}
/// cumpute 封装 Isolate 不需要管理生命周期
void computeTest() async {
print('外部代码1');
int x = await compute(func1, 10);
print(x);
print('外部代码2');
}
int func1(int count){
return 1000;
}
/// 虽然是 单线程语言 但是仍可以实现多线程 Isolate
/// 不用担心多线程数据抢夺的问题 。 但是数据交互比较麻烦
/// 利用 port 传递参数
void test1() async {
print('外部代码1');
ReceivePort port = ReceivePort();
Isolate iso = await Isolate.spawn(func, port.sendPort);
port.listen((message) {
print(message);
port.close();
iso.kill();
});
sleep(Duration(seconds: 1));
print('外部代码2');
}
void func(SendPort send){print('搞定!');send.send(100000);}
