检测ThreadPool WorkItem是否已完成/等待完成

Question

无论出于何种原因,ThreadPool的QueueWorkItem没有一个返回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;
        }

    ...

编辑:我问了一个关于使用异步委托而不是ThreadPool时出现的问题的后续问题.

Answer 1

好吧,你在获取WaitHandle和设置它之间遇到了竞争条件.如果他们碰巧有点迟到,你真的希望呼叫者永远等待吗？

你或许应该做一些适当的锁定,并保持一个"我已经完成了"标志,这样,如果你做返回之前创建的WaitHandle它完成后,您可以设置它.

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