TL; DR： _由运行的任务中的死锁StaTaskScheduler。_长版：

我使用的是StaTaskScheduler从ParallelExtensionsExtras中通过平行小组，举办一些遗留STA
COM对象由第三方提供。StaTaskScheduler实现细节的描述如下：

好消息是，TPL的实现能够在MTA或STA线程上运行，并考虑到了诸如WaitHandle.WaitAll之类的基础API的相关差异（仅在为该方法提供多个等待句柄时才支持MTA线程）。

我认为这意味着TPL的阻塞部分将使用等待API，该API会CoWaitForMultipleHandles在STA线程上调用时泵送消息（例如），以避免出现死锁情况。

在我的情况下，我相信正在发生以下情况：进程内STA COM对象A对进程外对象B进行调用，然后期望通过B作为该传出调用的一部分从B进行回调。

以简化形式：

var result = await Task.Factory.StartNew(() =>
{
    // in-proc object A
    var a = new A(); 
    // out-of-proc object B
    var b = new B(); 
    // A calls B and B calls back A during the Method call
    return a.Method(b);     
}, CancellationToken.None, TaskCreationOptions.None, staTaskScheduler);

问题是，a.Method(b)永不返回。据我所知，发生这种情况是因为内部的某个阻塞等待BlockingCollection<Task>不会泵送消息，因此我对引用语句的假设可能是错误的。

编辑
的在测试WinForms应用程序的UI线程上执行时（即提供TaskScheduler.FromCurrentSynchronizationContext()而不是staTaskSchedulerto
Task.Factory.StartNew），可以使用相同的代码。

解决这个问题的正确方法是什么？我是否应该实现一个自定义同步上下文，该上下文将显式地使用泵送消息CoWaitForMultipleHandles，并将其安装在由其启动的每个STA线程上StaTaskScheduler？

如果是这样，将在底层实现BlockingCollection调用我的SynchronizationContext.Wait方法吗？我可以SynchronizationContext.WaitHelper用来实施SynchronizationContext.Wait吗？

*使用一些代码进行 *编辑 ，该代码表明在执行阻塞等待时托管的STA线程不会泵送。该代码是一个完整的控制台应用程序，可以复制/粘贴/运行：

using System;
using System.Collections.Concurrent;
using System.Runtime.InteropServices;
using System.Threading;
using System.Threading.Tasks;

namespace ConsoleTestApp
{
    class Program
    {
        // start and run an STA thread
        static void RunStaThread(bool pump)
        {
            // test a blocking wait with BlockingCollection.Take
            var tasks = new BlockingCollection<Task>();

            var thread = new Thread(() => 
            {
                // Create a simple Win32 window 
                var hwndStatic = NativeMethods.CreateWindowEx(0, "Static", String.Empty, NativeMethods.WS_POPUP,
                    0, 0, 0, 0, IntPtr.Zero, IntPtr.Zero, IntPtr.Zero, IntPtr.Zero);

                // subclass it with a custom WndProc
                IntPtr prevWndProc = IntPtr.Zero;

                var newWndProc = new NativeMethods.WndProc((hwnd, msg, wParam, lParam) =>
                {
                    if (msg == NativeMethods.WM_TEST)
                        Console.WriteLine("WM_TEST processed");
                    return NativeMethods.CallWindowProc(prevWndProc, hwnd, msg, wParam, lParam);
                });

                prevWndProc = NativeMethods.SetWindowLong(hwndStatic, NativeMethods.GWL_WNDPROC, newWndProc);
                if (prevWndProc == IntPtr.Zero)
                    throw new ApplicationException();

                // post a test WM_TEST message to it
                NativeMethods.PostMessage(hwndStatic, NativeMethods.WM_TEST, IntPtr.Zero, IntPtr.Zero);

                // BlockingCollection blocks without pumping, NativeMethods.WM_TEST never arrives
                try { var task = tasks.Take(); }
                catch (Exception e) { Console.WriteLine(e.Message); }

                if (pump)
                {
                    // NativeMethods.WM_TEST will arrive, because Win32 MessageBox pumps
                    Console.WriteLine("Now start pumping...");
                    NativeMethods.MessageBox(IntPtr.Zero, "Pumping messages, press OK to stop...", String.Empty, 0);
                }
            });

            thread.SetApartmentState(ApartmentState.STA);
            thread.Start();

            Thread.Sleep(2000);

            // this causes the STA thread to end
            tasks.CompleteAdding();

            thread.Join();
        }

        static void Main(string[] args)
        {
            Console.WriteLine("Testing without pumping...");
            RunStaThread(false);

            Console.WriteLine("\nTest with pumping...");
            RunStaThread(true);

            Console.WriteLine("Press Enter to exit");
            Console.ReadLine();
        }
    }

    // Interop
    static class NativeMethods
    {
        [DllImport("user32")]
        public static extern IntPtr SetWindowLong(IntPtr hwnd, int nIndex, WndProc newProc);

        [DllImport("user32")]
        public static extern IntPtr CallWindowProc(IntPtr lpPrevWndFunc, IntPtr hwnd, int msg, int wParam, int lParam);

        [DllImport("user32.dll")]
        public static extern IntPtr CreateWindowEx(int dwExStyle, string lpClassName, string lpWindowName, int dwStyle, int x, int y, int nWidth, int nHeight, IntPtr hWndParent, IntPtr hMenu, IntPtr hInstance, IntPtr lpParam);

        [DllImport("user32.dll")]
        public static extern bool PostMessage(IntPtr hwnd, uint msg, IntPtr wParam, IntPtr lParam);

        [DllImport("user32.dll")]
        public static extern int MessageBox(IntPtr hwnd, string text, String caption, int options);

        public delegate IntPtr WndProc(IntPtr hwnd, int msg, int wParam, int lParam);

        public const int GWL_WNDPROC = -4;
        public const int WS_POPUP = unchecked((int)0x80000000);
        public const int WM_USER = 0x0400;

        public const int WM_TEST = WM_USER + 1;
    }
}

产生输出：

测试无需抽水...
collection参数为空，并已被标记为完成添加。

抽水测试...
collection参数为空，并已被标记为完成添加。
现在开始抽水...
WM_TEST已处理
按Enter退出