博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
.NET 中使用 TaskCompletionSource 作为线程同步互斥或异步操作的事件
阅读量:4958 次
发布时间:2019-06-12

本文共 969 字,大约阅读时间需要 3 分钟。

 

你可以使用临界区(Critical Section)、互斥量(Mutex)、信号量(Semaphores)和事件(Event)来处理线程同步。然而,在编写一些异步处理函数,尤其是还有 async 和 await 使用的时候,还有一些更方便的类型可以用来处理线程同步。

使用 TaskCompletionSource,你可以轻松地编写既可以异步等待,又可以同步等待的代码来。


 

本文内容

 

等待事件

我们创建一个 TaskCompletionSource<object> 对象,这样,我们便可以写出一个既可以同步等待又可以异步等待的方法:

public class WalterlvDemo{
private readonly TaskCompletionSource _source = new TaskCompletionSource(); public Task WaitAsync() => _source.Task; public void Wait() => _source.Task.GetAwaiter().GetResult();}

等待时可以同步:

demo.Wait();

也可以异步:

await demo.WaitAsync();

而同步的那个方法,便可以用来做线程同步使用。

引发事件

要像一个事件一样让同步等待阻塞着的线程继续跑起来,则需要设置这个事件。

TaskCompletionSource<object> 提供了很多让任务完成的方法:

TaskCompletionSource 中的方法

可以通过让这个 TaskCompletionSource<object> 完成、取消或设置异常的方式让这个 Task 进入完成、取消或错误状态,然后等待它的线程就会继续执行;当然如果有异常,就会让等待的线程收到一个需要处理的异常。

_source.SetResult(null);

我的博客会首发于 ,而 CSDN 和博客园仅从其中摘选发布,而且一旦发布了就不再更新。

知识共享许可协议

本作品采用进行许可。欢迎转载、使用、重新发布,但务必保留文章署名吕毅(包含链接:),不得用于商业目的,基于本文修改后的作品务必以相同的许可发布。如有任何疑问,请。

转载于:https://www.cnblogs.com/walterlv/p/10236377.html

你可能感兴趣的文章
js05-DOM对象二
查看>>
mariadb BINLOG_FORMAT = STATEMENT 异常
查看>>
C3P0 WARN: Establishing SSL connection without server's identity verification is not recommended
查看>>
iPhone在日本最牛,在中国输得最慘
查看>>
动态方法决议 和 消息转发
查看>>
WPF自定义搜索框代码分享
查看>>
js 基础拓展
查看>>
C#生成随机数
查看>>
iOS CoreData介绍和使用(以及一些注意事项)
查看>>
Android应用程序与SurfaceFlinger服务的连接过程分析
查看>>
Java回顾之多线程
查看>>
sqlite
查看>>
机电行业如何进行信息化建设
查看>>
9、总线
查看>>
Git 笔记 - section 1
查看>>
HDU6409 没有兄弟的舞会
查看>>
2018 Multi-University Training Contest 10 - TeaTree
查看>>
2018 Multi-University Training Contest 10 - Count
查看>>
HDU6203 ping ping ping
查看>>
《人人都是产品经理》书籍目录
查看>>