子线程如何等待主线程中的某些内容完成？

Question

通常问题是主线程等待子线程，我可以在Task 上使用await。

但我有一种情况，子线程必须等待主线程中的某个方法完成才能继续。如何让这种交流成为可能？

public void MainThread()
{
    Task t = Task.Run(ChildThread); //not using await because we want to continue doing work that must be only on the main thread
    WorkA();
    WorkB();
    ???
    WorkC();
}

public async Task ChildThread()
{
    WorkD();
    ???
    Need_WorkB_ToBeCompletedBeforeThisOne();
}

WorkA WorkB WorkC 都必须在主线程上。在我的真实代码中，所有这些都是间接从子线程发出的，因为子线程需要它们完成但由于线程限制而无法完成。

我有办法让我的子线程告诉主线程已经开始工作（所以我将代码简化为您在此处看到的内容，一旦任务开始，工作将立即进行）但我需要一些方法发布者（子线程）了解这些命令的进度。

PS。感谢来自这个线程的答案，我为 Unity 创建了 CoroutineHost，您可以使用 await 可以从任何子线程向主线程发出的 yield IEnumerator 方法：https://github.com/5argon/E7Unity/tree/master/CoroutineHost

Answer 1

您正在寻找“信号”。由于子进程是异步的并且信号只使用一次，TaskCompletionSource<T> 会很好地工作：

public void MainThread()
{
  var tcs = new TaskCompletionSource<object>(); // Create the signal
  Task t = Task.Run(() => ChildThread(tcs.Task)); // Pass the "receiver" end to ChildThread
  WorkA();
  WorkB();
  tcs.SetResult(null); // Send the signal
  WorkC();
}

public async Task ChildThread(Task workBCompleted)
{
  WorkD();
  await workBCompleted; // (asynchronously) wait for the signal to be sent
  Need_WorkB_ToBeCompletedBeforeThisOne();
}

有关更多信息，请参阅my book 中的配方 11.4“异步信号”。如果您需要一个可以多次设置和取消设置的“信号”，那么您应该使用AsyncManualResetEvent。

Answer 2

如果 WorkB 是一个任务，我会想象这样的事情：

public void MainThread()
{
    Task workB = WorkB();
    ChildThread(workB); // you don't need to use Task.Run here, the task is ran automatically
    WorkA();
    WorkC();
}

public async Task ChildThread(Task otherTaskToWait)
{
    WorkD();
    await otherTaskToWait;
    Need_WorkB_ToBeCompletedBeforeThisOne();
}