Nito.AsyncEx:async/await的.Net辅助库。

玩点科技新鲜事 2024-08-11 19:36:34

我是编程乐趣,一个10年.Net开发经验老程序员,点击右上方“关注”,每天为你分享开源项目和编程知识。

推荐一个专为异步编程设计的开源项目。

01

项目简介

Nito.AsyncEx是一个功能强大且灵活的开源项目,它提供了一系列工具和扩展方法,使得开发者可以更加轻松地编写和管理异步任务。

02

项目功能与特性

该项目核心提供以下7个功能:

1、异步锁(AsyncLock)

允许任务以异步方式获取和释放锁,支持取消操作,解决了传统Lock在异步编程中的局限性。

2、异步事件(AsyncManualResetEvent和AsyncAutoResetEvent)

提供了异步版本的手动复位事件和自动复位事件,用于控制线程同步。

3、异步条件变量(AsyncConditionVariable)

与互斥锁一起使用,实现更复杂的线程同步模式。

4、异步监视器(AsyncMonitor)

提供了类似Monitor类的功能,但完全兼容异步操作。

5、异步信号量(AsyncSemaphore)

限制同时访问资源的数量,用于控制并发请求的数量。

6、异步倒计时事件(AsyncCountdownEvent)

当满足特定条件(即倒计到零)后触发,用于协调多个异步操作的完成。

7、异步读写锁(AsyncReaderWriterLock)

允许多个读者或单个写入者同时进行操作,提高了并发性能。

03

使用场景

常用的使用场景有:

在多线程环境中保护共享资源,避免死锁和竞态条件。实现异步阻塞,控制并发请求的数量。在微服务架构中,确保服务之间的调用顺序或按照特定逻辑同步执行。在需要异步编程支持的任何.NET应用程序中,简化异步代码的编写和管理。

04

使用示例

1、安装依赖

Install-Package Nito.AsyncEx

2、异步锁示例代码

// 引入Nito.AsyncEx库,下面使用该库提供异步锁(AsyncLock)等用于异步编程的实用工具  using Nito.AsyncEx; // 创建一个AsyncLock实例,用于控制对共享资源的异步访问 AsyncLock _mutex = new AsyncLock(); // 使用for循环模拟并发访问共享资源的场景 for(var i=0; i<20; i++) { // 调用异步方法UseLockAsync,传入当前迭代次数作为参数 // 注意:这里的调用是同步的,因为for循环本身不是异步的。但是,UseLockAsync内部会异步处理     UseLockAsync(i);    } // 定义一个异步方法UseLockAsync,该方法使用AsyncLock来异步地访问共享资源 async Task UseLockAsync(int index) {     // 使用await等待获取AsyncLock的锁   using (await _mutex.LockAsync()) {         // 在锁的保护下执行异步操作   await Task.Run(() => { Console.WriteLine(index); }); } } // 等待用户输入,防止程序立即退出 Console.ReadLine();

效果如下,保证按照顺序执行:

3、锁取消示例代码

using Nito.AsyncEx;AsyncLock _mutex = new AsyncLock();var cts = new CancellationTokenSource();// 设置一个超时时间或某个条件来触发取消 // 这里我们简单地使用延时来模拟 Task.Delay(2000).ContinueWith(_ => cts.Cancel());try{ await UseLockAsync(cts.Token);}catch (OperationCanceledException){ Console.WriteLine("操作被取消!");}Console.ReadLine();async Task UseLockAsync(CancellationToken cancellationToken){ using (await _mutex.LockAsync()) { try { // 模拟一个长时间运行的异步操作 // 注意:这里我们使用了Task.Delay来模拟,但它不是真实的长时间运行操作 // 在实际应用中,这里可能是网络请求、数据库操作等 await Task.Delay(5000, cancellationToken); Console.WriteLine("操作成功完成"); } catch (OperationCanceledException) { // 如果在Task.Delay中触发了取消,则捕获异常 Console.WriteLine("操作在锁内被取消。"); // 注意:一旦退出using块,锁就会被释放 } }}

效果如下:

05

项目地址

https://github.com/StephenCleary/AsyncEx

- End -

推荐阅读

0 阅读:5

玩点科技新鲜事

简介:感谢大家的关注