dart-notes

dart-notes

• Dart的Event Loop

• Future

• Function

Dart的EventLoop

Dart是单线程模型，是一种Event-Looper以及Event-Queue的模型，所有的事件都是通过EventLooper的依次执行。

Dart中的Main Isolate只有一个Event Looper，但是存在两个Event Queue:

Event Queue Microtask Queue

Microtask Queue中的Event优先被处理，直到Microtask Queue队列中的Event为空时，才会去执行Event Queue中的Event

代码以Microtask运行的方式

 //1
 scheduleMicrotask((){
        print('a microtask');
    });
 //2
 Future.microtask(() => print('在Microtask queue里运行的Future'));
 //3
 Futrue().then(() => print('then方法是Microtask运行方式'));

代码加入Event队列的方式

Timer.run((){
       print('a event');
   });

所以如下代码，并不会输出"executed"

main() {
   Timer.run(() { print("executed"); });  
    foo() {
      scheduleMicrotask(foo);  
    }
    foo();
  }

Future

dart中当执行return await () async {}的时候，实际上返回的是一个延迟计算的Future对象.

Future表示一个延迟的计算过程、任务，它的执行遵循Dart的Event Loop策略。

创建Future的两种方式（推荐第一种）

//第一种
Future myFunc() {
  return new Future(() async {
    //Do something
    var result = await http.get();
    return result;
  });

//第二种 多用于自定义的class中
Future<String> myFunc() {
  Completer<String> comp = new Completer<String>();
  //Do something
  comp.complete("...");

  return comp.future;
}

Future类的静态方法

 //Future(dynamic computation()) 
 Future myFunc() {
  return new Future(() async {
    //Do something
    var result = await http.get();
    return result;
  });
}

// Future.delayed(Duration duration, [dynamic computation()])
await Future.delayed(Duration(microseconds: 500));

//Future.sync(dynamic computation()) 同步执行的任务

//Future.value([value])
int result = await Future.delayed(Duration(milliseconds: 2000),(){
  return Future.value(123);
});

//Future.wait，当所有Future完成后，返回List值列表：
Future.wait([expensiveA(), expensiveB(), expensiveC()])
      .then((List responses) => chooseBestResponse(responses));

Future的公共方法

//then：异步操作逻辑在这里写。
new Future(() => futureTask)  //  异步任务的函数
        .then((m) => "futueTask execute result:$m")  //   任务执行完后的子任务
        .then((m) => m.length)  //  其中m为上个任务执行完后的返回的结果 上个任务也可以是一个异步函数

//whenComplete：异步完成时的回调。类似Java的finally。
new Future(() => futureTask)  //  异步任务的函数
        .then((m) => "futueTask execute result:$m")  //   任务执行完后的子任务
        .then((m) => m.length)  //  其中m为上个任务执行完后的返回的结果
        .then((m) => printLength(m))
        .whenComplete(() => whenTaskCompelete);


//catchError：捕获异常或者异步出错时的回调。
new Future(()=> throw 'we have a problem')
    .then((_)=> print('callback2'))
    .catchError((error)=>print('$error')));
    
//timeout: 超时
new Future.delayed(new Duration(seconds: 5), () => 1)
          .timeout(new Duration(seconds: 2))
          .then(print)
          .catchError(print);//超时未处理，此处将打印TimeoutException after 0:00:02.000000: Future not completed
  
 new Future.delayed(new Duration(seconds: 5), () => 1)
           .timeout(new Duration(seconds: 2), onTimeout: () => 0)
           .then(print) //此处打印0
           .catchError(print);  
    

Function