我有一个从多个线程经常调用的方法.它涉及使用await FileIO.WriteTextAsync写入磁盘.从单个线程调用它时工作正常,但是一旦我开始在多个线程中执行此操作,我会收到此错误:
The process cannot access the file because it is being used by another process.
我知道错误意味着什么,但我不知道如何解决它.通常,我会创建一个lock(object)语句,以确保一次只有一个线程访问该文件.但是,这是一个异步方法,因此我不能在lock(object)语句的主体中使用await运算符.
请告知如何处理此方案.
解决方法
您可以使用SemaphoreSlim充当异步兼容锁:
SemaphoreSlim _mutex = new SemaphoreSlim(1); async Task MyMethodAsync() { await _mutex.WaitAsync(); try { ... } finally { _mutex.Release(); } }
就个人而言,我不喜欢finally,所以我通常会编写自己的Idisposable来释放互斥锁,并且我的代码看起来像这样:
async Task MyMethodAsync() { // LockAsync is an extension method returning my custom Idisposable using (await _mutex.LockAsync()) { ... } }
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。