14 
Future readData() {
    var completer = new Completer();
    print("querying");
    pool.query('select p.id, p.name, p.age, t.name, t.species '
        'from people p '
        'left join pets t on t.owner_id = p.id').then((result) {
      print("got results");
      for (var row in result) {
        if (row[3] == null) {
          print("ID: ${row[0]}, Name: ${row[1]}, Age: ${row[2]}, No Pets");
        } else {
          print("ID: ${row[0]}, Name: ${row[1]}, Age: ${row[2]}, Pet Name: ${row[3]},     Pet Species ${row[4]}");
        }
      }
      completer.complete(null);
    });
    return completer.future;
  }

以上是取自 github SQLJocky Connector的示例代码

如果可能的话，我希望有人向我解释为什么在 pool.query 之外创建了一个完成器对象的函数然后调用了一个函数 completer.complete(null)。

简而言之，我无法理解打印执行后的部分。

注意：如果可能的话，我还想知道 future 和 Completer 如何用于 DB 和非 DB 操作的实际用途。

我探索了以下链接： Google groups Discussion on Future and Completer

和下面给出的 api 参考文档 Completer api 参考和Future api 参考

4

3 回答 3

26

从某种意义上说，该方法返回的 Future 对象连接到该完成者对象，该完成者对象将在“将来”的某个时间点完成。在 Completer 上调用 .complete() 方法，它向未来发出它已完成的信号。这是一个更简化的示例：

Future<String> someFutureResult(){
   final c = new Completer();
   // complete will be called in 3 seconds by the timer.
   new Timer(3000, (_) => c.complete("you should see me second"));
   return c.future;
}

main(){
   someFutureResult().then((String result) => print('$result'));
   print("you should see me first");
}

这是一篇博客文章的链接，其中详细介绍了期货有用的其他场景

于 2012-12-05T21:17:35.607 回答
3

Completer 用于为future 提供一个值，并发出信号以触发附加到future 的任何剩余回调和延续（即在调用站点/在用户代码中）。

这completer.complete(null)是用于向未来发出异步操作已完成的信号。完整的 API 表明它必须提供 1 个参数（即不是可选的）。

void complete(T value)

此代码对返回值不感兴趣，只是通知调用站点操作已完成。因为它只是打印，您需要检查控制台的输出。

于 2012-12-05T21:17:48.073 回答
3

正确答案在 DartPad 中有错误，原因可能是 Dart 版本。

error : The argument type 'int' can't be assigned to the parameter type 'Duration'.
error : The argument type '(dynamic) → void' can't be assigned to the parameter type '() → void'.

以下片段是补充

import 'dart:async';

Future<dynamic> someFutureResult(){
   final c = new Completer();
   // complete will be called in 3 seconds by the timer.
   new Timer(Duration(seconds: 3), () {     
       print("Yeah, this line is printed after 3 seconds");
       c.complete("you should see me final");       
   });
   return c.future;

}

main(){
   someFutureResult().then((dynamic result) => print('$result'));
   print("you should see me first");
}

结果

you should see me first
Yeah, this line is printed after 3 seconds
you should see me final
于 2019-06-14T04:09:57.010 回答