C# TaskCompletionSource的用法 - 将回调模式转换为async/await-C#.Net教程-PHP中文网

C# TaskCompletionSource的用法 - 将回调模式转换为async/await

煙雲

发布： 2025-12-08 17:57:14

原创

939人浏览过

TaskCompletionSource是C#中将回调式异步操作包装为可await的Task的核心工具，不执行异步逻辑，仅手动控制Task完成状态（成功/失败/取消），适用于桥接事件、回调、IAsyncResult等非Task异步模型。

c# taskcompletionsource<t>的用法 - 将回调模式转换为async/aw<a style= ait - php中文网"/>

TaskCompletionSource 是 C# 中把“回调式异步操作”包装成 Task<t></t>、从而支持 await 的核心工具。它不执行任何异步逻辑，只负责手动控制一个 Task 的完成状态（成功、失败、取消）。

什么时候需要 TaskCompletionSource

常见于以下场景：

调用老式 API（比如基于事件或回调的 SDK，如 WebSocket.OnMessage、HttpClient.SendAsync 的旧封装）
需要自己定义异步契约，比如实现超时控制、延迟触发、信号等待（类似 ManualResetEventSlim + Task）
桥接非 Task 的异步模型（如 Begin/End 模式、IAsyncResult）

基本用法：三步走

以“监听一次 WebSocket 消息”为例：

var tcs = new TaskCompletionSource<string>();// 1. 订阅回调（比如 WebSocket 收到消息时触发）
webSocket.OnMessage += (msg) =>
{
// 2. 成功完成 Task，值为 msg
tcs.TrySetResult(msg);
};// 3. 返回可 await 的 Task
return tcs.Task;

登录后复制

调用方就可以这样写：

string msg = await WaitForNextMessage(); // 干净、线性、可异常传播

登录后复制

务必注意 TrySetXXX 的安全性

TrySetResult/TrySetException/TrySetCanceled 是线程安全且幂等的 —— 多次调用只生效第一次，不会抛异常。推荐始终用 TrySet* 系列，而不是 Set*。

乾坤圈新媒体矩阵管家

新媒体账号、门店矩阵智能管理系统

219

查看详情

常见错误：

重复调用 SetResult → 抛 InvalidOperationException
在 Task 已完成后再设置 → 同样崩溃
忘记处理异常或取消路径 → Task 永远不完成（死等）

配合 CancellationToken 实现可取消等待

不能直接取消 TaskCompletionSource 本身，但可以监听 token 并主动取消：

var tcs = new TaskCompletionSource<string>();using var registration = cancellationToken.Register(() =>
{
tcs.TrySetCanceled(); // 注意：传入 token 可选，但建议显式传入
});// ... 后续回调中调用 TrySetResult 或 TrySetException

登录后复制

这样 await tcs.Task 就能响应 cancellationToken，抛出 OperationCanceledException。

基本上就这些。它不复杂，但容易忽略线程安全和完成唯一性 —— 用好 TrySet* 和及时清理资源（比如注销事件），就能稳稳把回调转成 async/await。

以上就是C# TaskCompletionSource的用法 - 将回调模式转换为async/await的详细内容，更多请关注php中文网其它相关文章！