如何调用多个异步函数（FIFO？）

Question

我花了很多时间寻找解决方案，但由于我是Dart begginer，我自己找不到它。我想要实现的是为应用程序运行时从代码中的不同点随机调用的一些异步函数（比如当用户点击我的应用程序中的按钮时）创建类似队列的东西。我希望它们按照调用的顺序执行，所以基本上我有异步方法，如updateDate（）和updatePoints（），当用户点击按钮X时，将调用updateDate（）（添加到队列中） ，和Y和updatePoints（）类似。当用户点击我。即X，X，Y我想按照这个确切的顺序运行updateDate（），updateDate（），updatePoints（）。当一个任务完成后，另一个任务就开始了。我想我不能用await来实现它。任何提示将不胜感激！

Answer 1

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

Answer 2

在大型任务队列中使用时，以下代码可能是一种不好的做法，但如果您确定任务数组不会超出足够的大小 - 这可能会很好：

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中，按原始顺序逐个执行函数。 try {...}数组用于存储返回值，最后返回所有值。

如果偶然发现错误，则执行停止并抛出。在这种情况下，结果数组会丢失。您可以将microtask闭包添加到每个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 ]
});

数组中的其他值。

用法示例：

qazxswpoi