无论出于何种原因, ThreadPoolQueueWorkItem 不会返回 IAsyncResult 或工作项的其他句柄,这将允许等待直到它完成。有 RegisterWait... 方法,但是您必须传递 WaitHandle 并且创建它们很昂贵(请参阅 IAsyncResult 文档,该文档建议您延迟创建 WaitHandle 直到被请求)。任务并行库将修复这一缺陷,但要等待很长时间才能使用。那么,这样的设计有什么问题吗:

public class Concurrent<T> {
    private ManualResetEvent _resetEvent;
    private T _result;

    public Concurrent(Func<T> f) {
        ThreadPool.QueueUserWorkItem(_ => {
                                         _result = f();
                                         if (_resetEvent != null)
                                             _resetEvent.Set();
                                     });
    }

    public WaitHandle WaitHandle {
        get {
            if (_resetEvent == null)
                _resetEvent = new ManualResetEvent(_result != null);
            return _resetEvent;
        }

    ...

编辑:
我问了 follow-up question about the concerns which arise when using async delegates instead of the ThreadPool

最佳答案

好吧,在获取 WaitHandle 和设置它之间存在竞争条件。如果他们碰巧迟到了一点,您真的希望来电者永远等待吗?

您可能应该做一些适当的锁定并保留一个“我已经完成”标志,以便如果您在完成后创建 WaitHandle,您可以在返回之前设置它。

我还会亲自编写一个静态工厂方法,而不仅仅是使用公共(public)构造函数 - 或者使其成为“创建然后显式启动”模式。在构造函数中排队工作项对我来说感觉很奇怪。

关于c# - 检测到 ThreadPool WorkItem 已完成/等待完成,我们在Stack Overflow上找到一个类似的问题:https://stackoverflow.com/questions/405600/

10-16 10:14