.NET 创建新的调度程序

Question

我正在尝试使用调度程序创建第二个线程，以便我可以让主调度程序（用于 UI）完全无压力，并且让 UI 不断响应。

现在，我可以为每个子线程（或 C# 中的 void）创建多个线程，但我是否有可能创建一个新线程并获取它的调度程序，然后调用它？这就是我所做的：

Private CheckLoopThread As New System.Threading.Thread(New System.Threading.ThreadStart(AddressOf CheckLoop))

CheckLoopThread.Priority = System.Threading.ThreadPriority.Lowest
CheckLoopThread.Start()
Dim Test As Windows.Threading.Dispatcher = Windows.Threading.Dispatcher.FromThread(CheckLoopThread)

但是，变量“Test”在执行“Nothing”之后。这怎么可能？是创建第二个调度程序的另一种方法吗？

欢迎以任何 .NET 形式提供答案。 Visual Basic 或 C#。我正在 .NET 4.0 框架上使用 VB.NET WPF。

提前致谢。

Answer 1

为什么要锁？

我更喜欢：

Dispatcher myDispatcher = null;

// create a manual reset event for crossthread signalling.
var dispatcherReadyEvent = new ManualResetEvent(false);

// create a new thread.
new Thread(new ThreadStart(() =>
{
    // get the current dispatcher (if it didn't exists
    // it will be created.
    myDispatcher = Dispatcher.CurrentDispatcher;
    // set the signal that the dispatcher is created.
    dispatcherReadyEvent.Set();
    // run the dispatcher.
    Dispatcher.Run();
})).Start();

// wait until the dispatcher is created on the thread.
dispatcherReadyEvent.WaitOne();

// run something on the dispatcher thread.
myDispatcher.Invoke(...);

Answer 2

Dispatcher.FromThread(... ) 不会创建 Dispatcher，如果尚未为线程创建 Dispatcher，则返回 null。要为线程创建调度程序，您必须访问 Dispatcher.CurrentDispatcher 至少在您的 CheckLoopThread 上运行一次。正如 MSDN 上针对 Dispatcher.CurrentDispatcher 所说：

如果 Dispatcher 没有与当前线程关联，则创建一个新的 Dispatcher
将创建调度程序。 FromThread 的情况并非如此
方法。如果没有调度程序，FromThread 将返回 null
与指定线程关联

Answer 3

我实际上正在创建很多这样的调度程序，我想正确的方法是以下几行：

object theLock = new object();
Dispatcher dispatcher = null;

lock (theLock)
{
    new Thread(new ThreadStart(() =>
    {
        lock (theLock)
        {
            dispatcher = Dispatcher.CurrentDispatcher;
            Monitor.Pulse(theLock);
        }
        Dispatcher.Run();
    })).Start();

    Monitor.Wait(theLock);
}

dispatcher.Invoke(...);

所有锁定似乎都很复杂，但理论上 Start() 方法可以在 之前返回>dispatcher 实际上已设置，因此调用它可能会导致没有锁的 NullReferenceException。