在单独的线程上调度托管 Win32 WndProc

Question

我正在通过非托管 CreateWindowEx 创建一个窗口，使用 PInvoke 作为服务器，以便调度来自不同进程的 SendMessage 调用。这应该包含在 同步 函数中（类注册 + 窗口创建），如下所示：

public bool Start()
{
    if (!Running)
    {
        var processHandle = Process.GetCurrentProcess().Handle;

        var windowClass = new WndClassEx
        {
            lpszMenuName = null,
            hInstance = processHandle,
            cbSize = WndClassEx.Size,
            lpfnWndProc = WndProc,
            lpszClassName = Guid.NewGuid().ToString()
        };

        // Register the dummy window class
        var classAtom = RegisterClassEx(ref windowClass);

        // Check whether the class was registered successfully
        if (classAtom != 0u)
        {
            // Create the dummy window
            Handle = CreateWindowEx(0x08000000, classAtom, "", 0, -1, -1, -1, -1, IntPtr.Zero, IntPtr.Zero, processHandle, IntPtr.Zero);
            Running = Handle != IntPtr.Zero;

            // If window has been created
            if (Running)
            {
                // Launch the message loop thread
                taskFactory.StartNew(() =>
                {
                    Message message;

                    while (GetMessage(out message, IntPtr.Zero, 0, 0) != 0)
                    {
                        TranslateMessage(ref message);
                        DispatchMessage(ref message);
                    }
                });
            }
        }
    }

    return Running;
}

但是，MSDN 声明 GetMessage retrieves a message from the calling thread's message queue，因此这是不可能的，因为它被包装在不同的线程/任务中。我不能简单地将CreateWindowEx 函数调用移动到taskFactory.StartNew() 范围内。

关于如何实现这一目标的任何想法？也许从 GetMessage 更改为 PeekMessage 可能（不过，第二个可能会占用大量 CPU）？

要求：

1. Start 应该是同步的
2. 每个Start调用都应该注册一个新类
3. 消息循环应该沿着GetMessage在不同的线程中调度

Answer 1

我不能简单地将 CreateWindowEx 函数调用移动到 taskFactory.StartNew() 范围内。

抱歉，您将不得不这样做。尽管您可以向驻留在另一个线程中的窗口发送/发布消息，但检索和分派消息不能跨线程边界工作。创建一个窗口、销毁该窗口以及为该窗口运行一个消息循环，都必须在同一个线程上下文中完成。

在您的情况下，这意味着所有这些逻辑都必须在您传递给 taskFactory.StartNew() 的回调中。

关于如何实现这一目标的任何想法？也许从 GetMessage 更改为 PeekMessage 可能（第二个可能会占用大量 CPU）？

这不会解决您的问题。 GetMessage() 和PeekMessage() 都只从调用线程的消息队列中拉取消息，并且该拉取只能返回调用线程拥有的窗口的窗口消息。这在他们的文档中明确说明：

GetMessage

hWnd

类型：HWND

要检索其消息的窗口句柄。 窗口必须属于当前线程。

如果 hWnd 为 NULL，GetMessage 检索消息属于当前线程的任何窗口，以及当前线程的消息队列中hwnd 值为 NULL 的任何消息（参见 @ 987654329@ 结构）。因此如果hWnd 为NULL，窗口消息和线程消息都会被处理。

如果hWnd为-1，GetMessage只检索当前线程的消息队列中hwnd值为NULL的消息，即PostMessage（当hWnd参数为NULL时）或@发布的线程消息987654334@.

PeekMessage

hWnd

类型：HWND

要检索其消息的窗口句柄。 窗口必须属于当前线程。

如果hWnd 为NULL，PeekMessage 将检索属于当前线程的任何窗口 的消息，以及当前线程的消息队列中hwnd 值为NULL 的任何消息（参见@ 987654338@ 结构）。因此如果hWnd为NULL，窗口消息和线程消息都会被处理。

如果hWnd 为-1，PeekMessage 只检索当前线程的消息队列中hwnd 值为NULL 的消息，即PostMessage 发布的线程消息（当hWnd 参数为NULL 时）或PostThreadMessage。

GetMessage() 和PeekMessage() 之间的唯一区别在于：

• GetMessage() 在队列为空时等待消息，而PeekMessage() 则不会。

• PeekMessage() 可以返回消息而不将其从队列中删除，而GetMessage() 不能。

现在，话虽如此，请尝试以下操作。它将保持与您的原始代码相同的语义，即它在退出之前等待创建新窗口。窗口创建只是在任务线程而不是调用线程中执行：

public bool Start()
{
    if (!Running)
    {
        Handle = IntPtr.Zero;

        var readyEvent = new ManualResetEventSlim();

        // Launch the message loop thread
        taskFactory.StartNew(() =>
        {
            var processHandle = Process.GetCurrentProcess().Handle;

            var windowClass = new WndClassEx
            {
                lpszMenuName = null,
                hInstance = processHandle,
                cbSize = WndClassEx.Size,
                lpfnWndProc = WndProc,
                lpszClassName = Guid.NewGuid().ToString()
            };

            // Register the dummy window class
            var classAtom = RegisterClassEx(ref windowClass);

            // Check whether the class was registered successfully
            if (classAtom != 0u)
            {
                // Create the dummy window
                Handle = CreateWindowEx(0x08000000, classAtom, "", 0, -1, -1, -1, -1, IntPtr.Zero, IntPtr.Zero, processHandle, IntPtr.Zero);
                Running = Handle != IntPtr.Zero; 
            }

            readyEvent.Set();

            if (Handle != IntPtr.Zero)
            {
                Message message;

                while (GetMessage(out message, IntPtr.Zero, 0, 0) != 0)
                {
                    TranslateMessage(ref message);
                    DispatchMessage(ref message);
                }

                // if the message queue received WM_QUIT other than
                // from the window being destroyed, for instance by
                // a corresponding Stop() method posting WM_QUIT
                // to the window, then destroy the window now...
                if (IsWindow(Handle))
                {
                    DestroyWindow(Handle);
                }

                Handle = IntPtr.Zero;
            }
        });

        readyEvent.Wait();
    }

    return Running;
}