当连续执行多个多线程测试时，测试运行停止

Question

我有一个带有静态ConcurrentQueue的类。一个类接收消息并将其放入队列中，而这个类上的另一个线程从该队列中读取消息并一次处理一个。使用cancellationtoken中止该方法。

清空队列的方法如下所示：

public async Task HandleEventsFromQueueAsync(CancellationToken ct, int pollDelay = 25)
{
    while (true)
    {
        if (ct.IsCancellationRequested)
        {
            return;
        }

        if(messageQueue.TryDequeue(out ConsumeContext newMessage))
        {
            handler.Handle(newMessage);
        }

        try
        {
            await Task.Delay(pollDelay, ct).ConfigureAwait(true);
        } 
        catch (TaskCanceledException)
        {
            return;
        }
    }
}

我的测试方法如下：

CancellationToken ct = source.Token;
Thread thread = new Thread(async () => await sut.HandleEventsFromQueueAsync(ct));
thread.Start();

EventListener.messageQueue.Enqueue(message1);
EventListener.messageQueue.Enqueue(message2);
await Task.Delay(1000);
source.Cancel(false);

mockedHandler.Verify(x => x.Handle(It.IsAny<ConsumeContext>()), Times.Exactly(2));

因此，我在自己的线程中启动我的出列方法，并使用一个新的取消令牌。然后我将一些消息排队，给进程一秒钟时间来处理它们，然后使用源代码。Cancel（false）结束线程并使方法返回。然后我检查处理程序被调用的次数是否正确。当然，我在几个变体中测试了这一点，使用不同的消息类型和中止出列方法的不同时间。

问题是，当我单独运行任何html" target="_blank">测试时，它们都会成功。但是，当我尝试将它们作为一个组运行时，VisualStudio并没有运行所有的测试。没有错误消息，并且它确实运行的测试成功，但是运行在第二次测试之后就停止了。

我不知道为什么会这样。我的测试在结构上都是一样的。我每次都会正确地中止退出队列的线程。

什么可以迫使VisualStudio停止测试运行，而不抛出任何类型的错误？

Answer 1

我已经解决了自己的问题。结果表明，新创建的线程抛出了一个异常，当线程抛出异常时，这些异常会被忽略，但它们仍然会阻止单元测试的发生。在修复导致异常的问题后，测试工作正常。

Answer 2

您正在将异步lambda传递给线程构造函数。线程构造函数不理解异步委托（不接受函数

建议：

1. 使用任务而不是线程。这样，在退出测试之前，你就可以等待一些东西了

CancellationToken ct = source.Token;
Task consumerTask = Task.Run(() => sut.HandleEventsFromQueueAsync(ct));

EventListener.messageQueue.Enqueue(message1);
EventListener.messageQueue.Enqueue(message2);
await Task.Delay(1000);
source.Cancel(false);
await consumerTask; // Wait the task to complete

mockedHandler.Verify(x => x.Handle(It.IsAny<ConsumeContext>()), Times.Exactly(2));

考虑使用BlockingCollection或像Channel这样的异步队列，而不是Conoline tQueue。轮询是一种笨拙而低效的技术。使用阻塞或异步队列，您不必执行循环等待新消息到达。您可以进入等待状态，并在新消息到达时立即通知。

使用ConfigureAwait（false）配置等待ConfigureAwait（true）是默认值，不执行任何操作。

考虑通过抛出<代码>操作取消定义> /代码>来传播取消。这是在中传播取消的标准方式。网因此，与其说：

if (ct.IsCancellationRequested) return;

...最好这样做：

ct.ThrowIfCancellationRequested();