正在等待来自多个线程的任务

本文关键字：线程 任务 在等待 | 更新日期: 2023-09-27 18:00:02

是否可以同时从两个不同的线程在同一个Task上调用Wait()？

例如，以下代码有效吗：

private BlockingCollection<Task> _queue = new BlockingCollection<Task>();
private Thread _taskPumpThread;
...
private void Run()
{
    _taskPumpThread= new Thread(() => TaskPump(...));
    _taskPumpThread.Start();
    DoNothing();
}
private void DoNothing()
{
    Task doNothing = new Task(() => Console.WriteLine("Doing nothing"));
    queue.Add(doNothing);
    doNothing.Wait(); // no try-catch for brevity
}
private void TaskPump(CancellationToken token)
{
    while (!token.IsCancellationRequested)
    {
         Task task = queue.Take();
         task.Start();
         task.Wait(); 
    }
}

动机：
我正在实现一个控制器，它最终将请求序列化到串行端口，并处理来自该端口的通知。这些请求可以从不同的线程发送，它们应该能够等待结果（或异常），但可以选择异步工作

我正在考虑上面的设计，因为Task可以很好地处理所有情况（同步结果、异步调用和异常）。

这里可以找到一个相关但不完全相同的问题。

正在等待来自多个线程的任务

我只回答您非常具体的问题。

如果你运行以下短程序，你会发现答案是是，你可以让多个线程等待同一任务：

public static void Main(string[] args)
{
    Task t = Task.Delay(10000);
    new Thread(() => { ThreadRun(t); }).Start();
    new Thread(() => { ThreadRun(t); }).Start();
    Console.WriteLine("Main thread exits"); // this prints immediately.
}
private static void ThreadRun(Task t)
{
    t.Wait();
    Console.WriteLine(Thread.CurrentThread.ManagedThreadId + " finished waiting"); // this prints about 10 seconds later.
}
相关文章：