延迟处理器

对 DelayQueue 的抽象，允许您创建带有相关数据的延迟。

用户可以使用 insert() 将数据添加到延迟映射中。当延迟通过在 .await 上调用 next() 时超时时，将删除并返回相关数据。用户还可以使用 remove() 预先从延迟映射中删除延迟。

示例

1. 将 3 个数字以 10 秒的延迟插入延迟映射中，并打印它们超时时的内容

let mut handler = DelayHandler::default();
// Adds 1, 2, 3 to the delay-map, each with 10s delay
handler.insert(1, Duration::from_secs(10));
handler.insert(2, Duration::from_secs(10));
handler.insert(3, Duration::from_secs(10));

// Expect a delay of ~10s, after which 1, 2, 3 should print to stdout, in quick succession.
while let Some(expired) = handler.next().await {
    println!("{}", expired);
}

2. 将 3 个数字以不同的延迟插入延迟映射中，并打印它们超时时的内容

let mut handler = DelayHandler::default();
// Adds 1, 2 to the delay-map, with different delays
handler.insert(1, Duration::from_secs(10));
handler.insert(2, Duration::from_secs(5));

// With a delay of ~5s between, the prints should come in the order of 2 and 1.
while let Some(expired) = handler.next().await {
    println!("{}", expired);
}

3. 将 3 个数字以不同的延迟插入延迟映射中，当延迟超时时删除并打印

let mut handler = DelayHandler::default();
// Adds 1, 2, 3 to the delay-map, each with different delays
handler.insert(1, Duration::from_secs(15));
handler.insert(2, Duration::from_secs(5));
handler.insert(3, Duration::from_secs(10));

// Remove 3 from the delay-map
handler.remove(&3);

// Prints should be in the order of first 2 and ~10s later 1.
while let Some(expired) = handler.next().await {
    println!("{}", expired);
}