为什么 SynchronizationContext 不能正常工作？

Question

我有以下代码：

[TestMethod]
public void StartWorkInFirstThread()
{
    if (SynchronizationContext.Current == null)
        SynchronizationContext.SetSynchronizationContext(
            new SynchronizationContext());

    var syncContext = SynchronizationContext.Current;

    Console.WriteLine("Start work in the first thread ({0})", 
        Thread.CurrentThread.ManagedThreadId);

    var action = ((Action) DoSomethingInSecondThread);
    action.BeginInvoke(CallbackInSecondThread, syncContext);

    // Continue its own work
}

private static void DoSomethingInSecondThread()
{
    Console.WriteLine("Do something in the second thread ({0})", 
        Thread.CurrentThread.ManagedThreadId);   
}

private void CallbackInSecondThread(IAsyncResult ar)
{
    Console.WriteLine("Callback in the second thread ({0})", 
        Thread.CurrentThread.ManagedThreadId);
    var syncContext = (SynchronizationContext) ar.AsyncState;
    syncContext.Post(CallbackInFirstThread, null);
}

private void CallbackInFirstThread(object obj)
{
    Console.WriteLine("Callback in the first thread ({0})",
        Thread.CurrentThread.ManagedThreadId);
}

我希望最后一个方法在第一个线程中执行，即从中获取 SynchronizationContext 的初始线程，因为我调用此上下文的 Post() 方法。即是这样的：

Start work in the first thread (28)
Do something in the second thread (17)
Callback in the second thread (17)
Callback in the first thread (28)

这不就是SynchronizationContext的意义吗？但实际上我有以下输出：

Start work in the first thread (28)
Do something in the second thread (17)
Callback in the second thread (17)
Callback in the first thread (7)

问题是什么？ SynchronizationContext 是否出了问题或者我有一些误解？

更新： 我将此方法称为使用 Resharper 测试运行程序的单元测试。

Answer 1

请参阅http://www.codeproject.com/KB/threads/SynchronizationContext.aspx

这就是您需要的答案。您必须重写 SynchronizationContext 才能使其正确处理您的操作。

阅读开始于：

请注意，DoWork 的执行时间为
线程 11，与 Run1 相同的线程。
没有太多的 SynchronizationContext
进入主线程。为什么？什么是
发生什么事了？嗯...这就是部分
当你意识到没有什么是为了
生活中自由。线程不能只是
在它们之间切换上下文，它们
必须有内置的基础设施
为了做到这一点。用户界面
例如，线程使用消息
泵，并在其内
SynchronizationContext，它利用
消息泵同步到 UI
线程。

Answer 2

SynchronizationContext 的默认实现仅在调用中执行传递的委托线程（在调用 Send/Post 方法的线程中，而不是在捕获上下文的线程中）。如果您需要一些特定的行为，例如某些操作的线程关联性，您应该手动实现它。 BCL 包含一些用于简化 UI 互操作性的现成实现，例如 WindowsFormsSynchronizationContext 或 DispatcherSynchronizationContext。

Answer 3

您的期望是错误的，因为没有通用的方法将委托“注入”到正在运行的线程中。您的“第一个线程”在测试运行器中启动，将执行一个或多个测试，然后停止 - 无法中断它并告诉它运行 CallbackInFirstThread 。 SynchronizationContext 类在线程池中运行 Post ed 委托，因为这是它唯一的选项。

WindowsFormsSynchronizationContext 等派生类利用 WinForms 应用程序中的消息循环将 Post 委托传递给 UI 线程，但测试运行程序中没有等效的方法。

如果您想检查您正在测试的代码正在使用哪个 SynchronizationContext，您可以创建自己的派生类，该类设置一个您可以在测试中检查的标志。下面是一个示例：

public class TestSynchronizationContext : SynchronizationContext
{
    [ThreadStatic]
    private static object _CurrentPostToken;
    /// <summary>
    /// Gets the context's token, if the current thread is executing a delegate that
    /// was posted to this context; otherwise, null.
    /// </summary>
    public static object CurrentPostToken
    {
        get
        {
            return _CurrentPostToken;
        }
    }

    public object Token { get; private set; }

    /// <summary>
    /// Gets a WaitHandle that is set after the context executes a posted delegate.
    /// </summary>
    public AutoResetEvent PostHandle { get; private set; }

    public TestSynchronizationContext(object token)
    {
        Token = token;
        PostHandle = new AutoResetEvent(false);
    }

    public override void Post(SendOrPostCallback d, object state)
    {
        try
        {
            _CurrentPostToken = Token;
            // Execute the callback on this thread, so that we can reset the context
            // when it's finished.
            d(state);
        }
        finally
        {
            _CurrentPostToken = null;
        }

        // The test method will wait on this handle so that it doesn't exit before
        // the synchronization context is called.
        PostHandle.Set();
    }
}

在 StartWorkInFirstThread 中，将上下文设置为 TestSynchronizationContext 的实例：

SynchronizationContext.SetSynchronizationContext(
        new TestSynchronizationContext(new object()));

调用 BeginInvoke 后，需要等待 >Post 在退出测试之前发生，因此调用：

((TestSynchronizationContext)SynchronizationContext.Current).PostHandle.WaitOne(1000);

在 CallbackInFirstThread 中，您可以检查正在使用的上下文，例如：

Assert.IsNotNull(TestSynchronizationContext.CurrentPostToken);

关键是没有简单的方法来实际回发到第一个线程，但您可以检查是否使用了正确的上下文，以便当您的代码在实际应用程序中运行时，回调将在 UI 线程中运行。