我应该在我的 Task.Run() 中使用 await 吗？

Question

** 我在底部总结了这个问题，并进行了编辑**

以前有人问过这个问题，但我认为我的情况不同。

我正在同时处理多个请求。

这是我的代码，它在循环中运行。为简洁起见，我删除了一些处理 taskAllocated 变量的代码。

 while (!taskAllocated)
 {
     lock (_lock)
     {
         // Find an empty slot in the task queue to insert this task
         for (i = 0; i < MaxNumTasks; i++)
         {
             if (_taskQueue[i] == null)
             {
                 _taskQueue[i] = Task.Run(() => Process());
                 _taskQueue[i].ContinueWith(ProcessCompleted);
                 break;
             }
         }
     }
  }

Process是一个典型的async Task Process() { CpuIntensiveStuff(); }方法。

我一直在运行上面的代码，并且运行良好。它很好地多线程。每当有一个项目进来时，它就会在任务队列中找到一个空槽，然后将其启动。当任务完成时，ProcessCompleted 方法运行，并释放槽。

但后来我想，我不应该在我的Task.Run 中使用await 吗？比如：

_taskQueue[i] = Task.Run(async () => await Process());

想了想，我也不确定。 ContinueWith 在任务完成后正确触发，因此可能没有必要。

我问是因为我想监控和记录每项任务需要多长时间才能完成。

因此，我将创建另一种方法，而不是 Process()：

async Task DoProcess() 
{ 
    var sw = Stopwatch.StartNew();
    Process();
    sw.Stop();
    Log(sw.ElapsedMilliseconds);
}

我突然想到，如果我这样做了，我不确定是否需要await Process();，除了不知道我是否应该在Task.Run() 中等待

我对此有点紧张。谁能提供指导？

---

编辑：

总结一下：

如果某个方法是：

void SomeMethod() { }

然后

Task.Run(() => SomeMethod()); 很棒，在一个新的“线程”上调用 SomeMethod（技术上不是，但你知道我的意思）。

然而，我的SomeMethod其实是：

async Task SomeMethod() { }

您需要对Task.Run() 做一些特别的事情吗？

我的代码，我不是，我只是直接忽略了它是一个异步任务，而且这似乎有效：

Task.Run(() => SomeMethod()); // SomeMethod is async Task but I am ignoring that

但我不相信它 a) 应该有效或 b) 是一个好主意。替代方法可能是：

Task.Run(async() => await SomeMethod());

但是有什么意义吗？而这与我真正想做的事实相得益彰：

Task.Run(() => 
{ 
    someCode(); 
    var x = startTimer();
    SomeMethod(); 
    var y = stopTimer();
    someMoreCode()
}); 

但如果没有等待，我不确定它是否会等待某个方法完成并且计时器会出错。

Answer 1

如果您不使用匿名方法，事情就会变得更加清晰。例如，

Task.Run(() => Process())

等价于：

Task.Run(DoSomething);

Task DoSomething() {
    return Process();
}

而

Task.Run(async () => await Process())

等价于：

Task.Run(DoSomething);

async Task DoSomething() {
    await Process();
}

在大多数情况下，return SomethingThatReturnsATask() 和return await SomethingThatReturnsATask() 之间没有功能上的区别，您通常希望直接返回Task 而不要使用await（原因描述为here）。在 Task.Run 内部使用时，如果 .NET 团队没有您的支持，事情很容易变糟。

请务必注意，异步方法开始在同一个线程上运行，就像任何其他方法一样。魔法发生在第一个await，它作用于不完整的Task。此时，await返回它自己不完整的Task。这很重要 - 它返回，并承诺稍后再做。

这可能意味着只要Process()返回Task，从Task.Run返回的Task就会完成。由于Process() 在第一个await 处返回Task，这将在尚未完全完成时发生。

.NET 团队支持您

但情况并非如此，因为Task.Run 有一个specific overload for when you give it a method returning a Task。如果你look at the code，它会返回一个Task *，它与你返回的Task 相关联。

这意味着从Task.Run(() => Process()) 返回的Task 在从Process() 返回的Task 完成之前不会完成。

所以你的代码是好的。