C#如何为指定代码段的WrapService调用添加超时控制

调用wrapservice对接各子服务时，需要给服务调用增加1秒超时控制，因涉及变量较多不适合大范围改造代码，目标是在_merchantLegacyAPIWrapper.WrapService方法调用点直接实现超时逻辑。
现有业务代码如下：

public Stream Posnet(Stream request)
{
    if (!Globals.IsConsumerAuthorizedForWasService)
    {
        throw new FaultException("consumer is not authorized", new FaultCode("3001"));
    }

    var streamReader = new StreamReader(request);
    string streamString = streamReader.ReadToEnd();
    streamReader.Close();

    PosnetResponse resp = _merchantLegacyAPIWrapper.WrapService(streamString); // 需在此处添加超时控制

    string responseXml = SerializeResponse(resp);
    return GenerateStreamFromString(responseXml);
}

此前尝试通过Task.Wait实现超时未生效，尝试代码如下：

using System.Threading.Tasks;

var task = Task.Run(() => SomeMethod(input));
if (task.Wait(TimeSpan.FromSeconds(10)))
    return task.Result;
else
    throw new Exception("Timed out");

• Task.Wait触发超时后，仅会让当前等待的主线程跳出阻塞状态，后台执行WrapService的工作线程不会被终止，会持续运行直到调用自然结束，既浪费线程资源，高并发场景下极易打满线程池，还可能出现后台线程访问已释放资源抛出未知异常的问题
• 未单独处理任务执行过程中抛出的业务异常，所有错误会被包裹在AggregateException中，无法区分是超时错误还是服务本身的业务错误，排查成本高

方案1：调用点轻量封装（改造成本最低，适配不大范围改代码的需求） #

通过CancellationTokenSource+Task.WaitAny实现超时判断，超时后主动触发取消标记，代码如下：

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

// 配置1秒超时
private const int ServiceTimeoutMs = 1000;

public Stream Posnet(Stream request)
{
    if (!Globals.IsConsumerAuthorizedForWasService)
    {
        throw new FaultException("consumer is not authorized", new FaultCode("3001"));
    }

    using var streamReader = new StreamReader(request);
    string streamString = streamReader.ReadToEnd();
    PosnetResponse resp;

    using var cts = new CancellationTokenSource(ServiceTimeoutMs);
    var serviceTask = Task.Run(() => _merchantLegacyAPIWrapper.WrapService(streamString), cts.Token);
    
    // 等待服务返回或超时触发
    var completedIndex = Task.WaitAny(serviceTask, Task.Delay(ServiceTimeoutMs, cts.Token));
    if (completedIndex == 0)
    {
        // 服务正常返回，直接取结果，原生业务异常会正常抛出不会被包裹
        resp = serviceTask.GetAwaiter().GetResult();
    }
    else
    {
        // 触发超时，取消任务并抛超时异常
        cts.Cancel();
        throw new TimeoutException("服务调用超时，1秒内未获取返回结果");
    }

    string responseXml = SerializeResponse(resp);
    return GenerateStreamFromString(responseXml);
}

注意：该方案属于调用层软超时，如果WrapService方法本身不支持传入CancellationToken中断执行，超时后底层的网络请求不会被主动断开，只是上层逻辑不再等待结果。如果需要完全终止超时的请求，优先用方案2。

方案2：客户端原生超时配置（最优方案，无资源泄漏） #

如果_merchantLegacyAPIWrapper底层是标准服务客户端实现，直接在客户端初始化阶段配置超时是最稳妥的方案，从请求根源控制超时，不会出现线程泄漏问题：

• 若为WCF客户端：给绑定配置设置SendTimeout = TimeSpan.FromSeconds(1)
• 若为HttpClient实现：初始化客户端时设置Timeout = TimeSpan.FromSeconds(1)，或给单个请求传入带超时配置的CancellationToken
• 若为自研包装类：直接修改WrapService内部逻辑，给实际的网络请求步骤加超时控制，支持传入取消标记

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