async-await - Dart:如何管理异步函数中的并发

Question

我真的很喜欢 Dart 中的异步/等待模式。 它允许我编写可读的方法。

但是，有一些问题是有问题的，特别是，我根本不知道如何管理。

问题是，通过在方法内使用 async 和多个 wait，我们在方法中引入了并发性。 例如，如果我有一个方法:

Future<int> foo(int value) async {
await foo2();
await foo3();
await foo4();
int ret = foo5(value);
return ret;
}

嗯，这是一个非常简单的例子。 这里的问题是，对于每个等待，该方法都被放入事件循环中。 当您理解它时，这是可以的，但这并不能阻止您的应用程序在重新调整值之前再次调用该方法。

考虑该方法是否管理类实例公用的数据，而不是方法本身公用的数据。

所以，我尝试了以下解决方案:

bool isWorking = false;

Future<int> foo(int value) async {
if (isWorking) return foo(value);
isWorking = true;

await foo2();
await foo3();
await foo4();
int ret = foo5(value);

isWorking = False;

return ret;
}

据我了解，调用 future 方法会立即将其放入事件循环中，因此我认为该方法的并发调用的执行被延迟到第一个方法结束。 但事实并非如此，程序进入了死循环。

谁能给我解释一下这个问题并给出解决方案？

编辑: 一般来说，我认为像其他语言一样，有一个同步关键字可能很有趣，这意味着该方法如果第二次调用，将等到第一次结束。 像这样的东西:

Future<int> foo(int value) async synchronized {

编辑2:

我真的很兴奋，因为我想我已经解决了这个困扰我很长时间的问题。感谢 Argenti，特别是 Alexandre 给了我解决方案。我只是简单地重组了该解决方案以便于重用(至少对我来说)，并将其发布在此处我创建的类以及如何为可能需要它的人使用它的示例(请自行承担风险;-))。 我使用了 mixin，因为我发现它很实用，但如果您愿意，也可以单独使用 Locker 类。

myClass extends Object with LockManager {

  Locker locker = LockManager.getLocker();

  Future<int> foo(int value) async {

   _recall() {
      return foo(value);
   } 

   if (locker.locked) {
     return await locker.waitLock();
   }
   locker.setFunction(_recall);
   locker.lock();

   await foo2();
   await foo3();
   await foo4();
   int ret = foo5(value);

   locker.unlock();

   return ret;
  }
}

类(class)是:

import 'dart:async';

class LockManager {

static Locker getLocker() => new Locker();

}

class Locker {

  Future<Null> _isWorking = null;
  Completer<Null> completer;
  Function _function;
  bool get locked => _isWorking != null;

  lock() {
    completer = new Completer();
    _isWorking = completer.future;
  }

  unlock() {
    completer.complete();
    _isWorking = null;
  }

  waitLock() async {
      await _isWorking;
      return _function();
  }

  setFunction(Function fun) {
    if (_function == null) _function = fun;
  }

}

我以这种方式构建代码，以便您可以在类中的多个方法中轻松使用它。在这种情况下，每个方法都需要一个 Locker 实例。 我希望它有用。

Answer 1

您可以使用 Future 和 Completer 来代替 bool 值。实现你想要的:

Future<Null> isWorking = null;

Future<int> foo(int value) async {
  if (isWorking != null) {
    await isWorking; // wait for future complete
    return foo(value);
  }

  // lock
  var completer = new Completer<Null>();
  isWorking = completer.future;

  await foo2();
  await foo3();
  await foo4();
  int ret = foo5(value);

  // unlock
  completer.complete();
  isWorking = null;

  return ret;
}

第一次调用方法isWorking为null，不进入if部分并创建isWorking 作为 Future，将在方法结束时完成。如果在第一个调用完成 Future isWorking 之前对 foo 进行了其他调用，则该调用将进入 if 部分并等待 future isWorking 来完成。这对于在第一个调用完成之前可以完成的所有调用都是相同的。一旦第一个调用完成(并且 isWorking 设置为 null)，等待的调用就会收到通知，它们将再次调用 foo。其中一个将输入 foo 作为第一次调用，并且将完成相同的工作流程。

参见https://dartpad.dartlang.org/dceafcb4e6349acf770b67c0e816e9a7更好地查看工作流程。