gpt4 book ai didi

c# - 排队异步代码以顺序执行

转载 作者:太空狗 更新时间:2023-10-29 19:47:04 24 4
gpt4 key购买 nike

在任何时候,我都可以收到需要长时间运行的操作才能满足的方法调用。

有几种方法。因为它们共享资源,所以它们不能同时运行很重要 - 每个都应该按顺序运行。

通常,我会简单地按顺序调用:

var result1 = await Foo1Async();
var result2 = await Foo2Async();

但是,在这种情况下,对我的方法调用是异步的:

void Bar1()
{
var result = await Foo1Async();
// ...
}

void Bar2()
{
var result = await Foo2Async();
// ...
}

我想我需要使用 Task.ContinueWith,并且想到了这个:

readonly object syncLock = new Object();

private Task currentOperationTask = TaskUtilities.CompletedTask;
public Task<TResult> EnqueueOperation<TResult>(Func<Task<TResult>> continuationFunction)
{
lock (this.syncLock)
{
var operation = this.currentOperationTask.ContinueWith(predecessor => continuationFunction()).Unwrap();
this.currentOperationTask = operation;
return operation;
}
}

我是这样使用它的:

void Bar1()
{
var result = await EnqueueOperation(() => Foo1Async());
// ...
}

void Bar2()
{
var result = await EnqueueOperation(() => Foo2Async());
// ...
}

这是解决这个问题的正确方法吗?有什么我应该注意的陷阱吗?

最佳答案

您的代码可以正常工作,我认为这是解决问题的合理方法。

一个更简单的方法是使用 AsyncLock from Nito AsyncEx :

private readonly AsyncLock asyncLock = new AsyncLock();

public async Task<TResult> EnqueueOperation<TResult>(
Func<Task<TResult>> continuationFunction)
{
using (await asyncLock.LockAsync())
{
return await continuationFunction();
}
}

关于c# - 排队异步代码以顺序执行,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/17517442/

24 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com