任务.继续执行顺序
本文关键字:顺序 执行 继续 任务 | 更新日期: 2023-09-27 18:33:36
显然,我不明白如何使用ContinueWith方法。我的目标是执行任务,完成后返回一条消息。
这是我的代码:
public string UploadFile()
{
if (Request.Content.IsMimeMultipartContent())
{
//Save file
MultipartFormDataStreamProvider provider = new MultipartFormDataStreamProvider(HttpContext.Current.Server.MapPath("~/Files"));
Task<IEnumerable<HttpContent>> task = Request.Content.ReadAsMultipartAsync(provider);
string filename = "Not set";
task.ContinueWith(o =>
{
//File name
filename = provider.BodyPartFileNames.First().Value;
}, TaskScheduler.FromCurrentSynchronizationContext());
return filename;
}
else
{
return "Invalid.";
}
}
变量"文件名"始终返回"未设置"。似乎从未调用过 ContinueWith 方法中的代码。(如果我在 VS 中逐行调试它,它确实会被调用。
此方法在我的 ASP.NET Web API控制器/Ajax POST中被调用。
我在这里做错了什么?
如果您使用的是异步操作,最好的方法是也使您的操作异步,否则您将失去您正在进行的异步调用的优势。尝试按如下方式重写方法:
public Task<string> UploadFile()
{
if (Request.Content.IsMimeMultipartContent())
{
//Save file
MultipartFormDataStreamProvider provider = new MultipartFormDataStreamProvider(HttpContext.Current.Server.MapPath("~/Files"));
Task<IEnumerable<HttpContent>> task = Request.Content.ReadAsMultipartAsync(provider);
return task.ContinueWith<string>(contents =>
{
return provider.BodyPartFileNames.First().Value;
}, TaskScheduler.FromCurrentSynchronizationContext());
}
else
{
// For returning non-async stuff, use a TaskCompletionSource to avoid thread switches
TaskCompletionSource<string> tcs = new TaskCompletionSource<string>();
tcs.SetResult("Invalid.");
return tcs.Task;
}
}
未设置变量的原因是:
- 任务已实例化,但不会运行。
- 即使任务运行,函数也可能在它们完成运行之前返回,因此,它仍然会返回"未设置"。对此的修复是等待最终任务(设置
fileName
(完成。
您的代码可以像这样修复:
public string UploadFile()
{
if (Request.Content.IsMimeMultipartContent())
{
//Save file
MultipartFormDataStreamProvider provider = new MultipartFormDataStreamProvider(HttpContext.Current.Server.MapPath("~/Files"));
Task<IEnumerable<HttpContent>> task = Request.Content.ReadAsMultipartAsync(provider);
string filename = "Not set";
var finalTask = task.ContinueWith(o =>
{
//File name
filename = provider.BodyPartFileNames.First().Value;
}, TaskScheduler.FromCurrentSynchronizationContext());
task.Start();
finalTask.Wait();
return filename;
}
else
{
return "Invalid.";
}
}
新增内容如下:
- 将返回值
task.ContinueWith
分配给名为finalTask
的变量。我们需要这个任务,因为我们会等待它完成 - 已开始任务(
task.Start();
行( - 等待最终任务完成后返回 (
finalTask.Wait();
(
请考虑不要异步实现,因为最终它是同步的(您正在等待它完成(,并且当前的实现增加了可能可以避免的复杂性。
考虑按照以下思路做一些事情(如果可能的话(:
public string UploadFile()
{
if (Request.Content.IsMimeMultipartContent())
{
//Save file
MultipartFormDataStreamProvider provider = new MultipartFormDataStreamProvider(HttpContext.Current.Server.MapPath("~/Files"));
Request.Content.ReadAsMultipart(provider); // don't know if this is really valid.
return provider.BodyPartFileNames.First().Value;
}
else
{
return "Invalid.";
}
}
免责声明:我实际上没有执行上述代码;我写它只是为了说明应该做什么。
您应该从方法返回类型 Task<T>
,在这种情况下,它将是一个Task<string>
。
您正在使用异步操作。如果要等待其完成,则必须使用任务的Wait
方法:
task.ContinueWith(o =>
{
//File name
filename = provider.BodyPartFileNames.First().Value;
).Wait();
return filename;
编辑:某些异步方法会在创建任务后立即启动任务,而其他方法则要求您显式启动它们。您必须查阅每个文档才能确定。在这种情况下,任务似乎会自动启动。