TaskCompletionSource是C#中将回调式异步操作包装为可await的Task的核心工具，不执行异步逻辑，仅手动控制Task完成状态（成功/失败/取消），适用于桥接事件、回调、IAsyncResult等非Task异步模型。
TaskCompletionSource 是 C# 中把“回调式异步操作”包装成 Task、从而支持 await 的核心工具。它不执行任何异步逻辑，只负责手动控制一个 Task 的完成状态（成功、失败、取消）。
什么时候需要 TaskCompletionSource
常见于以下场景：
调用老式 API（比如基于事件或回调的 SDK，如 WebSocket.OnMessage、HttpClient.SendAsync 的旧封装）需要自己定义异步契约，比如实现超时控制、延迟触发、信号等待（类似 ManualResetEventSlim + Task）桥接非 Task 的异步模型（如 Begin/End 模式、IAsyncResult）
基本用法：三步走
以“监听一次 WebSocket 消息”为例：
var tcs = new TaskCompletionSource();// 1. 订阅回调（比如 WebSocket 收到消息时触发）webSocket.OnMessage += (msg) =>{// 2. 成功完成 Task，值为 msgtcs.TrySetResult(msg);};// 3. 返回可 await 的 Taskreturn tcs.Task;
调用方就可以这样写：
string msg = await WaitForNextMessage(); // 干净、线性、可异常传播
务必注意 TrySetXXX 的安全性
TrySetResult/TrySetException/TrySetCanceled 是线程安全且幂等的 —— 多次调用只生效第一次，不会抛异常。推荐始终用 TrySet* 系列，而不是 Set*。
常见错误：
重复调用 SetResult → 抛 InvalidOperationException在 Task 已完成后再设置 → 同样崩溃忘记处理异常或取消路径 → Task 永远不完成（死等）
配合 CancellationToken 实现可取消等待
不能直接取消 TaskCompletionSource 本身，但可以监听 token 并主动取消：
var tcs = new TaskCompletionSource();using var registration = cancellationToken.Register(() =>{tcs.TrySetCanceled(); // 注意：传入 token 可选，但建议显式传入});// ... 后续回调中调用 TrySetResult 或 TrySetException
这样 await tcs.Task 就能响应 cancellationToken，抛出 OperationCanceledException。
基本上就这些。它不复杂，但容易忽略线程安全和完成唯一性 —— 用好 TrySet* 和及时清理资源（比如注销事件），就能稳稳把回调转成 async/await。
以上就是C# TaskCompletionSource的用法 – 将回调模式转换为async/await的详细内容，更多请关注创想鸟其它相关文章！
版权声明：本文内容由互联网用户自发贡献，该文观点仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。
如发现本站有涉嫌抄袭侵权/违法违规的内容， 请发送邮件至 chuangxiangniao@163.com 举报，一经查实，本站将立刻删除。
发布者：程序猿，转转请注明出处：https://www.chuangxiangniao.com/p/1442807.html
微信扫一扫 
支付宝扫一扫 
