dart
Asynchrone Programmierung
Suche…
Eine Zukunft mit einem Completer zurückgeben
Future<Results> costlyQuery() {
var completer = new Completer();
database.query("SELECT * FROM giant_table", (results) {
// when complete
completer.complete(results);
}, (error) {
completer.completeException(error);
});
// this returns essentially immediately,
// before query is finished
return completer.future;
}
Async und Await
import 'dart:async';
Future main() async {
var value = await _waitForValue();
print("Here is the value: $value");
//since _waitForValue() returns immediately if you un it without await you won't get the result
var errorValue = "not finished yet";
_waitForValue();
print("Here is the error value: $value");// not finished yet
}
Future<int> _waitForValue() => new Future((){
var n = 100000000;
// Do some long process
for (var i = 1; i <= n; i++) {
// Print out progress:
if ([n / 2, n / 4, n / 10, n / 20].contains(i)) {
print("Not done yet...");
}
// Return value when done.
if (i == n) {
print("Done.");
return i;
}
}
});
Siehe Beispiel auf Dartpad: https://dartpad.dartlang.org/11d189b51e0f2680793ab3e16e53613c
Rückrufe in Futures umrechnen
Dart verfügt über eine robuste async-Bibliothek mit Future , Stream und mehr. Manchmal laufen jedoch möglicherweise asynchrone APIs, die Callbacks anstelle von Futures verwenden . Um die Lücke zwischen Callbacks und Futures zu schließen, bietet Dart die Completer- Klasse an. Sie können einen Completer verwenden, um einen Rückruf in eine Zukunft umzuwandeln.
Completers eignen sich hervorragend zum Überbrücken einer Callback-basierten API mit einer Future-basierten API. Angenommen, Ihr Datenbanktreiber verwendet keine Futures, Sie müssen jedoch eine Zukunft zurückgeben. Versuchen Sie diesen Code:
// A good use of a Completer.
Future doStuff() {
Completer completer = new Completer();
runDatabaseQuery(sql, (results) {
completer.complete(results);
});
return completer.future;
}
Wenn Sie eine API verwenden, die bereits eine Zukunft zurückgibt, müssen Sie keinen Completer verwenden.