使用 TPL 将“Disposable”对象安全地传递到 UI 线程

Question

我们最近采用 TPL 作为运行一些繁重后台任务的工具包。

这些任务通常会生成一个实现 IDisposable 的单个对象。这是因为它内部有一些操作系统句柄。

我想要发生的是，后台线程生成的对象将始终得到正确处理，即使在切换与应用程序关闭同时发生时也是如此。

经过一番思考，我这样写：

    private void RunOnUiThread(Object data, Action<Object> action)
    {
        var t = Task.Factory.StartNew(action, data, CancellationToken.None, TaskCreationOptions.None, _uiThreadScheduler);
        t.ContinueWith(delegate(Task task)
            {
                if (!task.IsCompleted)
                {
                    DisposableObject.DisposeObject(task.AsyncState);
                }
            });            
    }

后台Task调用RunOnUiThread将其结果传递给UI线程。任务t在UI线程上调度，并获取传入的data的所有权。我期望如果t无法执行因为 ui 线程的消息泵已关闭，所以延续将运行，我可以看到任务失败，并自行处置该对象。 DisposeObject() 是一个帮助器，用于在处置对象之前检查该对象是否实际上是 IDisposable 且非 null。

可悲的是，它不起作用。如果我在创建后台任务 t 后关闭应用程序，则不会执行延续。

我之前解决过这个问题。当时我正在使用 Threadpool 和 WPF Dispatcher 在 UI 线程上发布消息。虽然不是很漂亮，但最终还是成功了。我希望 TPL 在这种情况下能做得更好。如果我能以某种方式教导 TPL，如果它们实现了 IDisposable，它应该处理所有剩余的 AsyncState 对象，那就更好了。

所以，代码主要是为了说明问题。我想了解任何允许我将 Disposable 对象从后台任务安全地移交给 UI 线程的解决方案，并且最好是代码尽可能少的解决方案。

Answer 1

当进程关闭时，它的所有内核句柄都会自动关闭。您不必担心这一点：

http://msdn.microsoft.com/en-us/library/windows/desktop/ms686722(v=vs.85).aspx

Answer 2

查看 RX 库。这可能会让你做你想做的事。

Answer 3

来自 MSDN：

IsCompleted 当任务处于这三个任务之一时将返回 true
最终状态：RanToCompletion、Faulted 或 Canceled

换句话说，您的 DisposableObject.DisposeObject 永远不会被调用，因为在上述条件之一发生之后，总是会安排继续。我相信你的意思是：（

t.ContinueWith(t => DisposableObject.DisposeObject(task.AsyncState),
               TaskContinuationOptions.NotOnRanToCompletion)

顺便说一句，你可以简单地捕获 data 变量，而不是使用 AsyncState 属性）

但是我不会对某些事情使用延续您希望确保始终发生这种情况。我相信 try-finally 块在这里更合适：

private void RunOnUiThread2(Object data, Action<Object> action)
{
    var t = Task.Factory.StartNew(() => 
    {
        try
        {
            action(data);
        }
        finally
        {
            DisposableObject.DisposeObject(task.AsyncState); 
            //Or use a new *foreground* thread if the disposing is heavy
        }
    }, CancellationToken.None, TaskCreationOptions.None, _uiThreadScheduler);
}