我花了很多时间寻找解决方案,但由于我是Dart乞丐,我无法自己找到它。我想要实现的是,在应用程序运行时,为一些异步函数创建类似队列的东西,这些异步函数在应用程序运行时从代码中的不同点随机调用(假设,当用户在我的应用程序中点击按钮时(。我希望它们按照调用的顺序执行,所以基本上我有异步方法,如 updateDate(( 和 updatePoints((,当用户点击按钮 X 时,updateDate(( 将被调用(添加到队列(,类似于 Y 和 updatePoints((。当用户点击 X, X, Y 时,我想按此确切顺序运行 updateDate((、updateDate((、updatePoints((。当一个任务完成时,另一个任务正在启动。我想我不能使用等待来实现这一目标。任何提示将不胜感激!
import 'dart:async';
import 'dart:collection';
import 'dart:math';
Future<void> main() async {
_simulateRealWork();
}
Scheduler _scheduler = Scheduler();
class Scheduler {
bool _scheduled = false;
Queue<Future Function()> _queue = Queue<Future Function()>();
void schedule(Future Function() task) {
_queue.add(task);
if (!_scheduled) {
_scheduled = true;
Timer(Duration(seconds: 0), _execute);
}
}
Future _execute() async {
while (true) {
if (_queue.isEmpty) {
_scheduled = false;
return;
}
var first = _queue.removeFirst();
await first();
}
}
}
void _simulateRealWork() {
var maxPeriod = 5;
var count = 5;
for (var i = 0; i < count; i++) {
print('Timer $i');
var random = Random();
Timer(Duration(seconds: random.nextInt(maxPeriod)), () {
print('Scheduled work $i');
Future work() async {
print('Started work $i');
await Future.delayed(Duration(seconds: random.nextInt(maxPeriod)));
print('Ended work $i');
}
_scheduler.schedule(work);
});
}
}
结果:
Timer 0
Timer 1
Timer 2
Timer 3
Timer 4
Scheduled work 2
Started work 2
Scheduled work 0
Scheduled work 3
Ended work 2
Started work 0
Scheduled work 1
Scheduled work 4
Ended work 0
Started work 3
Ended work 3
Started work 1
Ended work 1
Started work 4
Ended work 4
在大型任务队列中使用时,以下代码可能是一种不好的做法,但如果您确定任务数组不会超过足够的大小 - 这可能工作得很好:
Future<List<T>> runOneByOne<T>(List<T Function()> list) {
if (list.isEmpty) {
return Future.value(null);
}
Future task = Future<T>.microtask(list.first);
final List<T> results = [];
for (var i = 1; i < list.length; i++) {
final func = list[i];
task = task.then((res) { results.add(res); return Future<T>.microtask(func); });
}
return task.then((res) { results.add(res); return results; });
}
它通过将一个Future
包装到另一个中,按原始顺序逐个执行函数。 results
数组用于存储返回的值,最后返回所有值。
如果发现错误,则执行停止并抛出。在这种情况下,结果数组将丢失。您可以向每个microtask
包装器添加try {...}
闭包以忽略错误并返回该特定任务中的null
,从而保留数组results
其他值。
使用示例:
runOneByOne<int>([
() { print("First"); return 1; },
() { print("Second"); return 2; },
() { print("Third"); return 3; },
]).then((results) {
print(results); // List<int> [ 1, 2, 3 ]
});