async-metronome

此 crate 实现了一个基于 William Pugh 和 Nathaniel Ayewah 在马里兰大学开发的 MutithreadedTC 的异步单元测试框架。

"MutithreadedTC 是一个用于测试并发应用程序的框架。它具有一个节拍器，用于对多个线程中的活动顺序提供精细控制。" ...

并发应用程序通常不是确定性的，因此它们的失败也不是。根据线程的交织方式，它们可能会出现和消失。

使用 async-metronome，可以定义测试用例来演示线程的固定交织顺序。如果测试中的并发抽象相对较小，则应该能够创建多个测试用例，以确定性地覆盖所有相关的交织。

为了避免在此处复制原始文档，请查看 MultithreadedTC 网站，以及相应的 论文。

示例

#[async_metronome::test]
async fn test_send_receive() {
    let (mut sender, mut receiver) = mpsc::channel::<usize>(1);

    let sender = async move {
        assert_tick!(0);
        sender.send(42).await.unwrap();
        sender.send(17).await.unwrap();
        assert_tick!(1);
    };
    
    let receiver = async move {
        assert_tick!(0);
        await_tick!(1);
        receiver.next().await;
        receiver.next().await;
    };

    let sender = async_metronome::spawn(sender);
    let receiver = async_metronome::spawn(receiver);

    sender.await;
    receiver.await;
}

说明（改编自 MutithreadedTC）

async-metronome 有一个内部时钟。只有在所有任务都处于挂起状态时，时钟才会前进到下一个滴答。

时钟从 tick 0 开始。在这个示例中，宏 await_tick!(1) 使接收器阻塞，直到时钟达到 tick 1 才继续。线程 1 在 tick 0 中可以自由运行，直到它在调用 sender.send(17) 时阻塞。此时，所有线程都阻塞了，时钟可以前进到下一个滴答。

在 tick 1 中，执行了接收者中的语句 receiver.next(42)，这释放了发送者。发送者中的最后一句话断言时钟在 tick 1，实际上断言任务在调用 sender.send(17) 时被阻塞。

完整的示例，可以在 tests/send_receive.rs 中找到。

安装

$ cargo add async-metronome

许可证