我有一种不能同时在多个线程中执行的方法(它写入一个文件).我不能使用锁,因为该方法是异步的.如何避免在另一个线程中调用该方法?而不是再次调用它,程序应该等待上一次调用完成(也异步).
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(); } }
原文地址:https://www.jb51.cc/csharp/93868.html
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。