我编写了一个线程池，如何通知使用它的方法任务已完成？

Question

假设我有一个方法，例如 ThreadPool.QueueTask(Delegate d)。

其中一些委托需要返回值，但由于它们无法执行此操作（作为委托传递），因此它们需要通过引用获取值作为参数。一旦任务完成，该值将被更改，因此调用方法需要知道这一点。

本质上，将任务传递给线程池的方法应该等待任务完成。

最好的方法是什么？我应该只做 Threadpool.QueueTask(Delegate d, EventWaitHandle e) 吗？或者是否有一种更优雅的方法，对于不熟悉此类事情的人来说是显而易见的？

亲切的问候， 河豚

Answer 1

您可以使用 ManualResetEvent：

public void TaskStartMethod()
{
    ManualResetEvent waitHandle = new ManualResetEvent(false);

    ThreadPool.QueueUserWorkItem(o=>
    {
        // Perform the task here

        // Signal when done
        waitHandle.Signal();
    });

    // Wait until the task is complete
    waitHandle.WaitOne();
}

本质上，该方法传递
线程池的任务应该是
等待直到完成。

上面的代码做到了这一点，但现在我有一个问题：如果你的方法正在等待任务完成，那么你为什么还要费心在单独的线程上执行该任务呢？换句话说，您所描述的是代码的顺序执行而不是并行，因此使用 ThradPool 是没有意义的。

或者，您可能希望使用单独的委托作为回调：

public delegate void OnTaskCompleteDelegate(Result someResult);

public void TaskStartMethod()
{
    OnTaskCompleteDelegate callback = new OnTaskCompleteDelegate(OnTaskComplete);
    ThradPool.QueueUserWorkItem(o=>
    {
        // Perform the task

        // Use the callback to notify that the
        // task is complete. You can send a result
        // or whatever you find necessary.
        callback(new Result(...));
    });

}

public void OnTaskComplete(Result someResult)
{
    // Process the result
}

更新 (1/24/2011)：
您甚至可能不需要回调委托，您可以直接调用 OnTaskComplete ，这也应该可以完成这项工作：

public void TaskStartMethod()
{
    ThradPool.QueueUserWorkItem(o=>
    {
        // Perform the task

        // Call the method when the task is complete
        OnTaskComplete(new Result(...));
    });
}

Answer 2

取决于你如何做。对我来说，这听起来有点像您让线程 A 将单个任务放入线程池中，然后等待该任务完成。这听起来不太有帮助。如果您将一项任务放入线程池并等待，只需在您自己的线程中执行即可。

但这可能不是你所做的！

我可以看到使用线程池的两种可能的好方法。线程 A 有多个任务需要并行启动，然后等待它们全部完成。在这种情况下，您需要存储所有任务（或结果类）的句柄，以便您可以等待它们全部完成。您可以使用半量或各种同步工具（我不专门使用 C#）来避免忙于轮询。

另一种方法是在任务结束时使用回调。线程A启动线程池中的任务，然后存在。该任务有一个返回启动它的类的句柄，并在完成时调用回调类型函数来执行终结类型的操作。