Ada*_*eeg 6 c# task task-parallel-library
我有一个任务,它运行一个循环并延迟每次迭代的间隔.一旦CancellationTokenSource电话Cancel()我想我主要的代码,Wait()为Task.Delay(interval)完成我的代码继续任务前退出循环.我认为这段代码可行,但事实并非如此.
相反,我的主代码t.Wait()在循环退出之前传递.为什么?
主要方法代码:
var cts = new CancellationTokenSource();
CancellationToken ct = cts.Token;
var t = Task.Run(() => { MyLoopTask(200, ct); });
// Prepare information
cts.Cancel();
t.Wait();
// Send Information
Run Code Online (Sandbox Code Playgroud)
任务代码
private async Task MyLoopTask(int interval, CancellationToken cancelToken)
{
while (!cancelToken.IsCancellationRequested)
{
Debug.Print(" Still In Loop ");
// Do something
await Task.Delay(interval);
}
Debug.Print(" cancelled ");
//Clean up
}
Run Code Online (Sandbox Code Playgroud)
您使用Task.Run该火灾创建任务并忘记您从中获取的实际任务MyLoopTask.
Task.Run这里多余.您可以调用MyLoopTask并使用它返回的任务.
var t = MyLoopTask(200, ct);
// ...
t.Wait();
Run Code Online (Sandbox Code Playgroud)
如果您仍有某些理由可以使用Task.Run,可以通过确保委托等待实际任务来完成此操作:
var t = Task.Run(async () => await MyLoopTask(200, ct));
// ...
t.Wait();
Run Code Online (Sandbox Code Playgroud)