- html - 出于某种原因,IE8 对我的 Sass 文件中继承的 html5 CSS 不友好?
- JMeter 在响应断言中使用 span 标签的问题
- html - 在 :hover and :active? 上具有不同效果的 CSS 动画
- html - 相对于居中的 html 内容固定的 CSS 重复背景?
我真的很喜欢 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 实例。我希望它有用。
最佳答案
您可以使用 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更好地查看工作流程。
关于async-await - Dart:如何管理异步函数中的并发,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/42071051/
我有一个 forEach循环处理数组中的数据。在该循环中间的某个地方,我必须等待 DOM 元素的更改,获取该更改,处理它,然后才能继续处理数组。 我希望在控制台中看到这个: Preparing "aa
给定以下方法: public async Task DoSomethingAsync() { // do some work await OpenSomeFileAsync();
尝试在 .exports 中运行一个异步函数,获取 Promise,然后在下一个异步函数中使用结果,但由于某种原因,无论等待如何,第二个函数都会在第一个函数之前执行。 销售.js = const sq
谁能解释为什么 c# 5 中的异步函数需要至少有 1 个等待?我找不到明确的理由/解释。 所谓必需,是指当异步函数内部没有任何 await 调用时编译器会发出警告,但不会抛出编译错误。 来自 this
我想用 Mocha 测试异步代码. 我跟着这个教程testing-promises-with-mocha .最后,它说最好的方法是 async/await。 以下是我的代码,我打算将 setTimeo
这个问题在这里已经有了答案: How do yield and await implement flow of control in .NET? (5 个答案) How is resumption
我想在 trait 中编写异步函数,但是因为 async fn in traits 还不被支持,我试图找到等效的方法接口(interface)。这是我在 Rust nightly (2019-01-0
在 node.js 中,我有一个数据库事务,我想在 then 回调中调用一个 async 方法,但我收到错误消息 关键字“等待”已保留。 这是异步 saveImage 函数: const saveIm
我正在包装 AspNet.Identity。但有些事情让我对 TPL 感到困惑。 第一个例子: public virtual async Task RemovePasswordAsync(st
我有三个 showDialog 示例。我认为 _showAlert1 是正确的,但它使用 2 个函数来实现它。 _showAlert2 也有效,但我认为它不正确,因为我认为 showDialog 是异
我正在编写一个应该尽可能快地执行所有异步函数的函数,但是,它们中只有 5 个可以同时运行。 我想使用 Promise.race 来实现,所以实现不是最好的。问题是代码执行不会在 await 处停止。我
在 Scala 和其他编程语言中,可以使用 Futures 和 Await。 (在实际代码中,会使用例如 zip+map 而不是 Await) def b1() = Future { 1 } def
这个问题在这里已经有了答案: At the end of an async method, should I return or await? (2 个回答) 8年前关闭。 我做了一些阅读,并认为我已
我知道这是一个非常开放的问题,我深表歉意。 我可以看到 Await.ready返回 Awaitable.type而 Await.result返回 T但我仍然混淆他们。 两者有什么区别? 一个是阻塞的,
为什么等待者(GetAwaiter - 使类可等待)是结构而不是类。使用类有什么坏处吗? public struct ConfiguredTaskAwaiter : ICriticalNotifyCo
这个问题在这里已经有了答案: Why doesn't Scala's Future have a .get / get(maxDuration) method, forcing us to resor
async/await 链中的所有函数都必须使用 async/await 关键字吗? async function one() { return await fetch(.....); } asy
点击组件的按钮时将执行以下方法。 async onClickButton() { await this.shoppingCartService.add(this.selectedOffer);
它似乎被记录在案的唯一地方是 this issue thread和 the actual specification .但是,删除的原因并没有在我能找到的任何地方发布。 新的推荐方式似乎是await
为什么使用 await 需要将其外部函数声明为 async? 例如,为什么这个 mongoose 语句需要它所在的函数来返回一个 promise? async function middleware(
我是一名优秀的程序员,十分优秀!