C#调用TaskCompletionSource.SetResult时同步执行延续任务的方法

核心结论 #

无法通过TaskCompletionSource的内置配置，100%强制所有关联延续在调用SetResult的线程上同步执行，也无法默认让SetResult等待所有延续执行完再返回。

你示例中传入TaskContinuationOptions.ExecuteSynchronously参数后依然出现三个线程ID不一致的问题，本质是因为这个枚举值只是给运行时的执行偏好提示，不是强制约束。出现以下任意一种情况时，运行时都会忽略该配置，把延续任务投递到线程池排队异步执行：

• 调用SetResult的线程无专属同步上下文（SynchronizationContext.Current为null，比如普通线程池线程）
• 延续任务指定了与当前线程不兼容的任务调度器
• 运行时判定同步执行存在栈溢出、死锁风险时，会主动降级为异步调度

你描述的期望行为为：

类似事件的Invoke方法：所有绑定的委托会在同一线程执行完成后，Invoke调用才会返回；如果延续任务内部存在await操作，则SetResult无需等待延续任务完全执行完成即可返回。

实现类事件Invoke行为的可行方案 #

该需求可以通过以下两种方案实现：

方案1：临时替换同步上下文，强制同步执行延续 #

通过在调用SetResult前临时挂载一个自定义的、直接同步执行回调的同步上下文，可以让所有未指定特殊调度器的延续全部在当前线程执行，执行完所有同步段后SetResult才会返回。
实现代码如下：

using System;
using System.Threading;
using System.Threading.Tasks;

// 自定义同步上下文：所有投递的回调直接在当前线程执行
public class InlineSyncContext : SynchronizationContext
{
    public override void Post(SendOrPostCallback d, object state) => Send(d, state);
    public override void Send(SendOrPostCallback d, object state) => d(state);
}

public class Program
{
    public static async Task Main()
    {
        var tcs = new TaskCompletionSource<string>(TaskContinuationOptions.ExecuteSynchronously);
        var task = Task.Run(async () =>
        {
            Console.WriteLine("Awaiting task on thread ID: {0}", Thread.CurrentThread.ManagedThreadId);
            await tcs.Task;
            // 同步延续段：会在SetResult调用线程执行
            Console.WriteLine("Continuation sync part on thread ID: {0}", Thread.CurrentThread.ManagedThreadId);
            
            await Task.Delay(100);
            // 异步延续段：正常调度，不阻塞SetResult返回
            Console.WriteLine("Continuation async part on thread ID: {0}", Thread.CurrentThread.ManagedThreadId);
        });
        await Task.Delay(100);
        Console.WriteLine("SetResult called on thread ID: {0}", Thread.CurrentThread.ManagedThreadId);
        
        // 替换上下文，同步执行所有延续
        var originalCtx = SynchronizationContext.Current;
        SynchronizationContext.SetSynchronizationContext(new InlineSyncContext());
        try
        {
            tcs.SetResult("done");
        }
        finally
        {
            SynchronizationContext.SetSynchronizationContext(originalCtx);
        }
        Console.WriteLine("SetResult returned on thread ID: {0}", Thread.CurrentThread.ManagedThreadId);
        
        await task;
    }
}

运行后输出符合预期：

Awaiting task on thread ID: 11
SetResult called on thread ID: 19
Continuation sync part on thread ID: 19
SetResult returned on thread ID: 19
Continuation async part on thread ID: <随机线程池ID>

方案2：显式封装延续注册逻辑 #

如果所有await TCS任务的代码都在你的可控范围内，可以直接封装TaskCompletionSource，自行维护延续委托列表：

• 对外暴露WaitAsync()方法代替直接访问tcs.Task，注册延续时把同步执行段存入列表
• 触发结果时先同步执行所有注册的同步延续，再调用SetResult
  该方案控制力更强，完全不受运行时默认调度逻辑影响，但缺点是无法约束外部代码直接访问原始TCS任务注册的延续。

注意事项 #

• 不要在UI线程（WPF/WinForm/MAUI）上强制同步执行来源未知的延续任务，极易引发死锁或UI长时间卡顿
• 同步执行延续和事件Invoke存在相同的锁重入风险，如果延续逻辑持有锁，需要做好重入防护
• 两种方案都只会阻塞到延续的第一个await点，await之后的逻辑会走正常的异步调度流程，正好匹配你期望的行为。

内容的提问来源于stack exchange，提问作者ANisus