- html - 出于某种原因,IE8 对我的 Sass 文件中继承的 html5 CSS 不友好?
- JMeter 在响应断言中使用 span 标签的问题
- html - 在 :hover and :active? 上具有不同效果的 CSS 动画
- html - 相对于居中的 html 内容固定的 CSS 重复背景?
我有一个复杂的基于任务/锁的困惑来执行“长”数据操作,我正在尝试用异步/等待替换它。我是异步等待的新手,所以我担心我犯了一些大错误。
为了简化事情,我的 UI 有几个页面依赖于相同的数据。现在,我只需要获取这些数据一次。所以我缓存它,以后的调用只是从缓存“CachedDataObjects”中获取它,而不是每次都进行长调用。
像这样(半伪代码):
private Dictionary<Guid,List<Data>> CachedDataObjects;
public async Task<List<Data>> GetData(Guid ID)
{
List<Data> data = null;
//see if we have any cached
CachedDataObjects.TryGetValue(ID, out data);
if (data == null)
{
if (ConnectedToServer)
{
data = new List<Data>();
await Task.Run(() =>
{
try
{
//long data call
data = Service.GetKPI(ID);
}
catch (Exception e)
{
//deal with errors (passes an action to do if resolved)
PromptForConnection(new Task(async () => { data = await GetData(ID); }), e);
}
});
}
CachedDataObjects.Add(ID, data);
}
return data;
}
但是,由于异步调用的性质,此方法会在两个页面被触发时被调用。
因此,出现异常 - 具有该 ID 的项目已添加到字典中。即使我修补了那个问题,潜在的问题仍然存在。 Data 对象将是不同的版本,我正在执行两个网络调用,而我应该只有一个等等。
之前,我通过将整个方法封装在一个 lock 语句中来“破解”了一个解决方案——因此只允许对其进行一次调用。我所有的数据加载都是在后台工作人员中完成的,第一个进行调用,一旦完成,其他人就会解锁以执行快速抓取。
但是我不能在异步方法中使用lock,反正这个方案感觉不太好。
异步方法是否可以“等待”其他异步调用完成?
最佳答案
你的问题是你是await
在将任务添加到字典之前先执行任务。在这种情况下,您需要将任务 添加到字典中,以便调用此方法的下一个页面将获得相同的任务:
public Task<List<Data>> GetData(Guid ID)
{
Task<List<Data>> task = null;
CachedDataObjects.TryGetValue(ID, out task);
if (task == null)
{
if (ConnectedToServer)
{
task = Task.Run(() =>
{
try
{
//long data call
return Service.GetKPI(ID);
}
catch (Exception e)
{
//deal with errors
}
});
}
DataObjects.Add(ID, task);
}
return task;
}
这将缓存任务。但是,如果 //deal with errors
传播异常,那么这也将缓存该异常。
为了避免这种情况,你可以使用更复杂的代码,或者你可以采用我的 AsyncLazy<T>
type :
private readonly ConcurrentDictionary<Guid, AsyncLazy<List<Data>>> CachedDataObjects;
public Task<List<Data>> GetData(Guid ID)
{
var lazy = CachedDataObjects.GetOrAdd(ID, id =>
new AsyncLazy<List<Data>>(() => Task.Run(() =>
{
try
{
return Service.GetKPI(ID);
}
catch (Exception e)
{
//deal with errors
throw;
}
}, AsyncLazyFlags.RetryOnFailure | AsyncLazyFlags.ExecuteOnCallingThread)));
return lazy.Task;
}
关于c# - async & await - 处理对同一方法的多次调用 - 锁定/等待彼此?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/38635349/
我有一个 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(
我是一名优秀的程序员,十分优秀!