Dispatcher.CurrentDispatcher 导致 ReactiveUI 调用挂起

Question

在 ReactiveCommand 上调用 .Execute() 在下面的示例中挂起或创建死锁。为什么会发生这种情况，避免这种情况的最佳方法是什么？

错误仅在调用Dispatcher.CurrentDispatcher时发生。不幸的是，不调用它的明显答案在较大的项目中不是一个选项。

我在项目中有nuget包reactui-core和reactui-winforms，都是v7.4.0。我使用 Resharper Visual Studio 进行了运行的 nunit 测试。

该代码是一个 NUnit 测试夹具，请注意 TimeoutAfterAsync 是一个辅助方法，用于在特定超时后取消测试，在没有此包装器的情况下观察到该行为

[TestFixture]
public class ReactiveCommandTests
{
    private static async Task<bool> ExecuteCommand()
    {
        await Task.Delay(1000);
        return true;
    }

    public static ReactiveCommand<Unit, bool> Command = ReactiveCommand.CreateFromTask(ExecuteCommand);
    public static ReactiveCommand<Unit, bool> CommandOnTaskpoolScheduler = ReactiveCommand.CreateFromTask(ExecuteCommand, outputScheduler: RxApp.TaskpoolScheduler);
    public static ReactiveCommand<Unit, bool> CommandAfterDispatcherInvoked = ReactiveCommand.CreateFromTask(ExecuteCommand);



    [Test, Order(1)]
    public async Task Test()
    {
        //THIS WORKS
        try
        {
            await TimeoutAfterAsync(
                Command.Execute(),
                TimeSpan.FromSeconds(5),
                "control");
        }
        catch (TimeoutException)
        {
            Assert.Fail("Control case timed out (not expected)");
        }
    }

    [Test, Order(2)]
    public async Task Test_CreateCommandAfterDispatcherCall()
    {
        //This line causes unwanted behaviour
        var x = Dispatcher.CurrentDispatcher;

        //THIS FAILS
        try
        {
            await TimeoutAfterAsync(
                CommandAfterDispatcherInvoked.Execute(),
                TimeSpan.FromSeconds(5),
                "after dispatcher creation");
        }
        catch (TimeoutException)
        {
            Assert.Fail("Executing commandAfterDispatcherInvoked timed out (expected, but not understood");
        }
    }

    [Test, Order(3)]
    public async Task Test_CreateCommandWithThreadpoolScheduler()
    {
        //This line causes unwanted behaviour
        var x = Dispatcher.CurrentDispatcher;

        //THIS WORKS AGAIN (using ThreadpoolScheduler when creating ReactiveCommand)
        try
        {
            await TimeoutAfterAsync(
                CommandOnTaskpoolScheduler.Execute(),
                TimeSpan.FromSeconds(5),
                "after dispatcher creation, with thread pool");
        }
        catch (TimeoutException)
        {
            Assert.Fail("ThreadpoolScheduler case timed out (not expected)");
        }
    }

    private static async Task<TResult> TimeoutAfterAsync<TResult>(IObservable<TResult> observable,
        TimeSpan timeout,
        string context)
    {
        var task = observable .ToTask();
        var result = await Task.WhenAny(task, Task.Delay(timeout));
        if (result == task)
        {
            // Task completed within timeout.
            return task.GetAwaiter().GetResult();
        }
        else
        {
            // Task timed out.
            throw new TimeoutException(context);
        }
    }
}

Answer 1

Dispatcher.CurrentDispatcher 很有趣；它 为当前线程创建 一个调度程序（如果它还没有的话）！这会导致单元测试出现问题，因为新的调度程序是为线程池线程创建的，它不是 STA 并且没有消息泵。

理想的 解决方案是不调用 CurrentDispatcher。曾经。使用 await 或 IProgress<T> 或（如果必须）SynchronizationContext 将 results/progress/events 与 UI 线程通信。这些抽象更容易为其创建测试环境。

但目前，您可以使用 WpfContext，一种包含在早期版本的 Async CTP 中的旧实用程序类型。 WpfContext.Run 将接受一个委托，为当前线程创建一个调度程序上下文，并在该调度程序上下文中执行委托，发送消息直到异步操作完成。

Dispatcher.CurrentDispatcher 导致 ReactiveUI 调用挂起

Dispatcher.CurrentDispatcher causes ReactiveUI call to hang

c#

dispatcher

winforms

reactiveui