测试任务延迟

Question

不知道如何实现这一点。我正在尝试对等待几分钟的方法进行单元测试，请参见此处：

internal class JctRestartViaSmsAttemptTestRunner : ITestRunner<JctRestartViaSmsAttempt>
{
    private readonly IMayWantMonitoring _queues;
    private readonly IAppSettings _appSettings;

    public JctRestartViaSmsAttemptTestRunner(IMayWantMonitoring queues, IAppSettings appSettings)
    {
        _queues = queues;
        _appSettings = appSettings;
    }

    public JctTest Execute(JctRestartViaSmsAttempt jctMessageType)
    {
        // after five minutes, publish an event to check if the JCT logged in
        var jctLoggedInTimeOut = TimeSpan.FromMinutes(double.Parse(_appSettings["JctLogInTimeOut"]));
        var message = new JctRestartViaSmsValidate(jctMessageType.Imei);

        Task.Delay(jctLoggedInTimeOut)
            .ContinueWith(x => _queues.Publish(message));

        // reset test values
        return new JctTest("6", jctMessageType.Imei, null, null, null);
    }
}

这是我的测试方法，但我无法模拟任务延迟的东西。

    [Test]
    public void TaskTest()
    {
        // arrange
        var imei = _fixture.Create<string>();
        _appSettings.Setup(c => c["JctLogInTimeOut"]).Returns("5");
        var message = _fixture.Build<JctRestartViaSmsAttempt>()
            .With(x => x.Imei, imei)
            .Create();

        var sut = _fixture.Create<JctRestartViaSmsAttemptTestRunner>();

        // act
        sut.Execute(message);

        // assert
        _queues.Verify(x => x.Publish(It.Is<JctRestartViaSmsValidate>(y => y.Imei == imei)));
    }

这是引发的错误：

Moq.MockException : 对模拟的预期调用至少一次， 但从未执行过：x => x.Publish(It.Is(y => y.Imei == .imei)) 否 配置的设置。未执行任何调用。在 Moq.Mock.ThrowVerifyException（MethodCall 预期，IEnumerable1 setups, IEnumerable1 actualCalls，Expression 表达式，Times 次， Int32 callCount) 在 Moq.Mock.VerifyCalls(Interceptor targetInterceptor、MethodCall 预期、Expression 表达式、Times 次）在 Moq.Mock.Verify[T](Mock1 mock, Expression1 表达式， 次次，字符串 failMessage) 在 Moq.Mock1.Verify(Expression1 表达式）在 JustEat.PrivateAPN.Worker.UnitTests.TestRunners.JctRestartViaSmsAttemptTestFixture.RunJctTest_WhenRestartAttemptSmsIsSent_ShouldPublishJctRestartValidateMessageWithTheRightImei() 在

我知道我需要自定义/配置我的灯具才能进入回调，但我不知道该怎么做，非常感谢任何帮助

Answer 1

您不应该在没有 await 的情况下触发 Task 以使其完成当您的测试和其他事情可能依赖于结果。

所以我建议你改成：

internal class JctRestartViaSmsAttemptTestRunner : ITestRunner<JctRestartViaSmsAttempt>
{
    private readonly IMayWantMonitoring _queues;
    private readonly IAppSettings _appSettings;

    public JctRestartViaSmsAttemptTestRunner(IMayWantMonitoring queues, IAppSettings appSettings)
    {
        _queues = queues;
        _appSettings = appSettings;
    }

    public async Task<JctTest> ExecuteAsync(JctRestartViaSmsAttempt jctMessageType)
    {
        // after five minutes, publish an event to check if the JCT logged in
        var jctLoggedInTimeOut = TimeSpan.FromMinutes(double.Parse(_appSettings["JctLogInTimeOut"]));
        var message = new JctRestartViaSmsValidate(jctMessageType.Imei);

        // this will now delay in a non blocking fashion.
        await Task.Delay(jctLoggedInTimeOut);

        _queues.Publish(message);

        // reset test values
        return new JctTest("6", jctMessageType.Imei, null, null, null);
    }
}

awaiting 的另一个原因是你有这个_queues，如果你打算稍后再读它，你永远不能保证内容，因为线程池中可能还有一个线程处理Task.Delay。

另类

如果您无法更改方法的签名，那么您将不得不使用Thread.Sleep()，这将阻塞当前线程直到它完成。

因为您确实指定了Task.Delay，所以我假设您使用它是为了获得非阻塞的好处。

如果您要使用Thread.Sleep()，您可能需要考虑在Task.Run() 中运行JctRestartViaSmsAttemptTestRunner，这样只会阻塞它正在运行的线程。

internal class JctRestartViaSmsAttemptTestRunner : ITestRunner<JctRestartViaSmsAttempt>
{
    private readonly IMayWantMonitoring _queues;
    private readonly IAppSettings _appSettings;

    public JctRestartViaSmsAttemptTestRunner(IMayWantMonitoring queues, IAppSettings appSettings)
    {
        _queues = queues;
        _appSettings = appSettings;
    }

    public JctTest Execute(JctRestartViaSmsAttempt jctMessageType)
    {
        // after five minutes, publish an event to check if the JCT logged in
        var jctLoggedInTimeOut = TimeSpan.FromMinutes(double.Parse(_appSettings["JctLogInTimeOut"]));
        var message = new JctRestartViaSmsValidate(jctMessageType.Imei);

        Thread.Wait(jctLoggedInTimeOut.Milliseconds);

        _queues.Publish(message);

        // reset test values
        return new JctTest("6", jctMessageType.Imei, null, null, null);
    }
}

测试

如果您有一个确实返回Task<> 的方法，那么如果您不能拥有async 测试方法签名，那么您将不得不使用.Result。如果您串行运行所有测试，这应该不是问题。如果你不知道为什么 .Result 和 .Wait() 不好读 here

所以对于你的异步版本：

JctTest test = runner.ExecuteAsync().Result;

并且您的非异步版本保持不变。

Answer 2

我认为问题在于允许完成测试。您在延迟开始后创建新任务，但测试功能本身在此之前完成。

我对测试框架并不太熟悉。但我希望你想在任务结束时使用 .Wait() 。这将创建一个阻塞任务，并且您的主测试线程将被阻塞，直到延迟结束。

Answer 3

execute 方法不是真正可测试的，因为它启动了一个延迟的任务，但您无法从外部管理该任务。

因此，您可以尝试使用Thread.Sleep，这不是很好，但应该可以：

[Test]
public void TaskTest()
{
    // arrange
    var imei = _fixture.Create<string>();
    _appSettings.Setup(c => c["JctLogInTimeOut"]).Returns("1");
    var message = _fixture.Build<JctRestartViaSmsAttempt>()
        .With(x => x.Imei, imei)
        .Create();

    var sut = _fixture.Create<JctRestartViaSmsAttemptTestRunner>();

    // act
    sut.Execute(message);

    // verify the task was not executed yet
    // ....

    // let the test thread sleep and give the task some time to run
    Thread.Sleep(2000);

    // assert
    _queues.Verify(x => x.Publish(It.Is<JctRestartViaSmsValidate>(y => y.Imei == imei)));
}