问如何在xUnit中同步并发运行的测试？

EN

[TestFixture]
public class ScheduleJobTest
{
    private static readonly Subject<Unit> s_tickets = new Subject<Unit>();

    [OneTimeSetUp]
    public static void SetUp()
    {
        Task.Run(() => s_tickets
            .Throttle(TimeSpan.FromSeconds(1))
            .SelectMany(_ => PollSchedulesNow())
            .DefaultIfEmpty()
            .GetAwaiter()
            .GetResult());
    }

    [OneTimeTearDown]
    public static void TearDown()
    {
        s_tickets.OnCompleted();
    }

    private static IObservable<Unit> PollSchedulesNow()
    {
        // Do something that eventually unblocks all the test cases
    }

    [TestCaseSource(nameof(ProvideNamespaces)), Parallelizable(ParallelScope.Children)]
    public void ScheduleJob(NamespaceConnectionInfo nci)
    {
        // Do something
        s_tickets.OnNext(Unit.Default);
        // Resume - blocks until the actions of PollSchedulesNow take effect
    }

    private static IEnumerable<TestCaseData> ProvideNamespaces()
    {
        return ...
    }
}