一个任务被取消了?

当有一个或两个任务时，它可以正常工作，但当我们列出多个任务时，会抛出错误“任务已取消”。

enter image description here

List<Task> allTasks = new List<Task>();
allTasks.Add(....);
allTasks.Add(....);
Task.WaitAll(allTasks.ToArray(), configuration.CancellationToken);




private static Task<T> HttpClientSendAsync<T>(string url, object data, HttpMethod method, string contentType, CancellationToken token)
{
HttpRequestMessage httpRequestMessage = new HttpRequestMessage(method, url);
HttpClient httpClient = new HttpClient();
httpClient.Timeout = new TimeSpan(Constants.TimeOut);


if (data != null)
{
byte[] byteArray = Encoding.ASCII.GetBytes(Helper.ToJSON(data));
MemoryStream memoryStream = new MemoryStream(byteArray);
httpRequestMessage.Content = new StringContent(new StreamReader(memoryStream).ReadToEnd(), Encoding.UTF8, contentType);
}


return httpClient.SendAsync(httpRequestMessage).ContinueWith(task =>
{
var response = task.Result;
return response.Content.ReadAsStringAsync().ContinueWith(stringTask =>
{
var json = stringTask.Result;
return Helper.FromJSON<T>(json);
});
}).Unwrap();
}
283724 次浏览
小开
最佳答案

有2个可能的原因会抛出TaskCanceledException:

  1. 在任务完成之前，与取消令牌相关联的CancellationTokenSource上的Cancel()。
  2. 请求超时，即没有在你在HttpClient.Timeout中指定的时间范围内完成。

我猜是暂停了。(如果它是一个明确的消去，你可能已经知道了。)你可以通过检查异常来确定:

try
{
var response = task.Result;
}
catch (TaskCanceledException ex)
{
// Check ex.CancellationToken.IsCancellationRequested here.
// If false, it's pretty safe to assume it was a timeout.
}
小开

我遇到了这个问题，因为我的Main()方法在返回之前没有等待任务完成，所以当我的控制台程序退出时，Task<HttpResponseMessage>正在被取消。

c#≥7.1

你可以使主方法异步化并等待任务。

public static async Task Main(){
Task<HttpResponseMessage> myTask = sendRequest(); // however you create the Task
HttpResponseMessage response = await myTask;
// process the response
}

c# & lt;7.1

解决方案是在Main()中调用myTask.GetAwaiter().GetResult()(从这个答案)。

小开

另一种可能是客户端没有等待结果。如果调用堆栈上的任何一个方法没有使用await关键字来等待调用完成，就会发生这种情况。

小开

另一个原因可能是，如果你正在运行服务(API)并在服务中放置了一个断点(并且你的代码被卡在某个断点上(例如Visual Studio解决方案显示调试而不是运行))。然后从客户端代码中点击API。所以如果服务代码在某个断点上暂停，你只需在VS中按F5。

小开 
var clientHttp = new HttpClient();
clientHttp.Timeout = TimeSpan.FromMinutes(30);
以上是等待大请求的最佳方法。 你对30分钟感到困惑;这是随机时间，你可以给出任何你想要的时间 换句话说，如果请求在30分钟前得到结果，则请求不会等待30分钟。 30分钟意味着请求处理时间为30分钟。 当我们发生错误“任务被取消”，或大数据请求需求
小开

在我的情况下，控制器方法不是异步的，控制器方法内部调用的方法是异步的。

所以我认为使用async/await来避免这些问题是很重要的。

小开

在我的。net核心3.1应用程序中，我得到两个问题，内部原因是超时异常。 一是我得到了聚合异常在它的内部异常是超时异常 2，其他情况是任务取消异常

我的解决方案是

catch (Exception ex)
{
if (ex.InnerException is TimeoutException)
{
ex = ex.InnerException;
}
else if (ex is TaskCanceledException)
{
if ((ex as TaskCanceledException).CancellationToken == null || (ex as TaskCanceledException).CancellationToken.IsCancellationRequested == false)
{
ex = new TimeoutException("Timeout occurred");
}
}
Logger.Fatal(string.Format("Exception at calling {0} :{1}", url, ex.Message), ex);
}
小开

我使用了一个简单的调用，而不是async。当我添加await并使方法async时，它开始正常工作。

public async Task<T> ExecuteScalarAsync<T>(string query, object parameter = null, CommandType commandType = CommandType.Text) where T : IConvertible
{
using (IDbConnection db = new SqlConnection(_con))
{
return await db.ExecuteScalarAsync<T>(query, parameter, null, null, commandType);
}
}
小开

推广@JobaDiniz的评论来回答:

不做了显而易见的事情，并释放了HttpClient实例，即使代码“;看起来是正确的”:

async Task<HttpResponseMessage> Method() {
using (var client = new HttpClient())
return client.GetAsync(request);
}

处理HttpClient实例会导致由其他HttpClient实例启动的HTTP请求被取消!

c#的新RIAA语法也是如此;稍微不那么明显:

async Task<HttpResponseMessage> Method() {
using var client = new HttpClient();
return client.GetAsync(request);
}

相反，正确的方法是为你的应用程序或库缓存HttpClient的静态实例，并重用它:

static HttpClient client = new HttpClient();


async Task<HttpResponseMessage> Method() {
return client.GetAsync(request);
}

(Async()请求方法所有线程都是安全的。)


提交答案