Flutter 之多线程

首先声明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);}