c# – 允许异步方法一次只调用一个实例

我有一种不能同时在多个线程中执行的方法(它写入一个文件).我不能使用锁,因为该方法是异步的.如何避免在另一个线程中调用该方法？而不是再次调用它,程序应该等待上一次调用完成(也异步).

例如,使用以下代码创建一个新的C#控制台应用程序：

using System;
using System.IO;
using System.Threading.Tasks;
namespace ConsoleApplication1 {
    internal class Program {
 
        private static void Main () {
            CallSlowStuff();
            CallSlowStuff();
            Console.ReadKey();
        }
 
        private static async void CallSlowStuff () {
            try {
                await DoSlowStuff();
                Console.WriteLine("Done!");
            }
            catch (Exception e) {
                Console.WriteLine(e.Message);
            }
        }
 
        private static async Task DoSlowStuff () {
            using (File.Open("_",FileMode.Create,FileAccess.Write,FileShare.None)) {
                for (int i = 0; i < 10; i++) {
                    await Task.Factory.StartNew(Console.WriteLine,i);
                    await Task.Delay(100);
                }
            }
        }
    }
}

在这个例子中,第二次调用CallSlowStuff会引发异常,因为它不能访问已经打开的文件.添加锁不是一个选项,因为锁和异步不会混合. (主要方法应该被认为是不可改变的)在实际应用中,CallSlowStuff是一种可以在任何地方调用的接口方法.

问题：如何使CallSlowStuff的后续调用等待当前运行的调用完成,而不阻塞主线程？可以使用async / await和任务(和Rx也可以)完成它吗？

解决方法

你需要某种异步锁. Stephen Toub整个 series of articles about building async synchronization primitives(包括 AsyncLock). AsyncLock的版本也包含在Stephen Cleary的 AsyncEx library中.

但可能更简单的解决方案是使用内置的SemaphoreSlim,它支持异步等待：

private static SemaphoreSlim SlowStuffSemaphore = new SemaphoreSlim(1,1);
 
private static async void CallSlowStuff () {
    await SlowStuffSemaphore.WaitAsync();
    try {
        await DoSlowStuff();
        Console.WriteLine("Done!");
    }
    catch (Exception e) {
        Console.WriteLine(e.Message);
    }
    finally {
        SlowStuffSemaphore.Release();
    }
}

c# – 允许异步方法一次只调用一个实例

解决方法

猜你在找的C#相关文章