异步方法启动新线程报错及流式HTTP请求超时终止方案问询

编译错误解释 #

ThreadStart 委托要求方法必须是无参数、无返回值的，但你的 GetCompaniesApi 有两个输入参数且返回 Task，签名完全不匹配，因此编译器抛出"No overload matches delegate"错误。

异步方法在新线程运行的正确写法 #

如果一定要用Thread（异步场景更推荐用Task体系），可以用lambda表达式包装方法调用，同时处理异步方法的返回（避免未捕获异常）：

Thread thread2 = new Thread(async () => 
{
    await GetCompaniesApi(_requestDuration, _startTimepoint);
});
thread2.Start();

更符合异步编程规范的方式是使用Task.Run，它会自动管理线程池资源：

Task task = Task.Run(async () => 
{
    await GetCompaniesApi(_requestDuration, _startTimepoint);
});

用Thread.Sleep+终止线程的方式不可靠（会导致资源泄漏，无法优雅保存数据），正确方案是使用CancellationTokenSource实现定时取消，让所有异步操作响应取消信号。

修改后的完整代码 #

public async Task GetCompanies(int requestDuration, long startTimepoint)
{
    // 创建自动在指定秒数后触发取消的令牌源
    using var cts = new CancellationTokenSource(TimeSpan.FromSeconds(requestDuration));
    try
    {
        await GetCompaniesApi(requestDuration, startTimepoint, cts.Token);
    }
    catch (OperationCanceledException)
    {
        // 处理请求被定时取消的逻辑，比如日志记录
        Console.WriteLine("请求已按计划终止");
    }
}

public async Task GetCompaniesApi(int requestDuration, long? startTimepoint, CancellationToken cancellationToken)
{
    string url = $"https://stream.companieshouse.gov.uk/companies?timepoint={startTimepoint}";

    // 发起HTTP请求时传入取消令牌，支持中途终止请求
    using HttpResponseMessage response = await _httpClient.GetAsync(url, HttpCompletionOption.ResponseHeadersRead, cancellationToken);
    using Stream streamToReadFrom = await response.Content.ReadAsStreamAsync(cancellationToken);
    
    string fileToWriteTo = Path.GetTempFileName();
    using Stream streamToWriteTo = System.IO.File.Open(fileToWriteTo, FileMode.Create);
    
    // 流式复制时传入取消令牌，触发取消后立即停止复制
    await streamToReadFrom.CopyToAsync(streamToWriteTo, cancellationToken);
    
    // 取消后，已写入文件的内容会被完整保留
    Console.WriteLine($"已保存内容到临时文件：{fileToWriteTo}");
}

关键说明 #

• CancellationTokenSource(TimeSpan)：自动在指定时间后触发取消，无需手动调用Cancel()。
• 所有异步操作（GetAsync、ReadAsStreamAsync、CopyToAsync）都传入取消令牌，确保这些操作能及时响应取消信号。
• 取消触发时会抛出OperationCanceledException，捕获该异常即可处理后续逻辑，此时文件已保存了截至取消前的所有内容。
• 避免手动终止线程，这种方式会导致HTTP连接、文件流等资源无法正确释放，不符合异步编程最佳实践。

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