Структура Interval

Завершается, когда наступает следующий момент времени в интервале.

Безопасность отмены

Этот метод безопасен для отмены. Если tick используется как ветвь в tokio::select! и первой завершается другая ветвь, то ни один тик не был потреблён.

Примеры

use tokio::time;

use std::time::Duration;

let mut interval = time::interval(Duration::from_millis(10));

interval.tick().await;
// approximately 0ms have elapsed. The first tick completes immediately.
interval.tick().await;
interval.tick().await;

// approximately 20ms have elapsed.

Ожидает наступления следующего момента времени в интервале.

Этот метод может вернуть следующие значения:

• Poll::Pending, если следующий момент времени ещё не наступил.
• Poll::Ready(instant), если следующий момент времени наступил.

Когда этот метод возвращает Poll::Pending, текущая задача планируется для пробуждения по истечении указанного времени. Обратите внимание, что при нескольких вызовах poll_tick пробуждение планируется только для Waker из Context, переданного при последнем вызове.

Сбрасывает интервал так, чтобы он завершился через один период от текущего момента.

Этот метод игнорирует стратегию MissedTickBehavior.

Это эквивалентно вызову reset_at(Instant::now() + period).

Примеры

use tokio::time;

use std::time::Duration;

let mut interval = time::interval(Duration::from_millis(100));

interval.tick().await;

time::sleep(Duration::from_millis(50)).await;
interval.reset();

interval.tick().await;
interval.tick().await;

// approximately 250ms have elapsed.

Немедленно сбрасывает интервал.

Этот метод игнорирует стратегию MissedTickBehavior.

Это эквивалентно вызову reset_at(Instant::now()).

Примеры

use tokio::time;

use std::time::Duration;

let mut interval = time::interval(Duration::from_millis(100));

interval.tick().await;

time::sleep(Duration::from_millis(50)).await;
interval.reset_immediately();

interval.tick().await;
interval.tick().await;

// approximately 150ms have elapsed.

Сбрасывает интервал по истечении указанного значения std::time::Duration.

Этот метод игнорирует стратегию MissedTickBehavior.

Это эквивалентно вызову reset_at(Instant::now() + after).

Примеры

use tokio::time;

use std::time::Duration;

let mut interval = time::interval(Duration::from_millis(100));
interval.tick().await;

time::sleep(Duration::from_millis(50)).await;

let after = Duration::from_millis(20);
interval.reset_after(after);

interval.tick().await;
interval.tick().await;

// approximately 170ms have elapsed.

Сбрасывает интервал на момент времени crate::time::Instant, соответствующий крайнему сроку.

Задаёт момент истечения следующего тика. Если указанный момент времени уже прошёл, для наверстывания будет использоваться стратегия MissedTickBehavior. Если указанный момент времени ещё не наступил, следующий тик завершится в этот момент, даже если для этого интервалу придётся ждать дольше, чем длится период этого Interval. Если у Interval были пропущенные тики до вызова этого метода, они отбрасываются.

Примеры

use tokio::time::{self, Instant};

use std::time::Duration;

let mut interval = time::interval(Duration::from_millis(100));
interval.tick().await;

time::sleep(Duration::from_millis(50)).await;

let deadline = Instant::now() + Duration::from_millis(30);
interval.reset_at(deadline);

interval.tick().await;
interval.tick().await;

// approximately 180ms have elapsed.

Возвращает используемую в данный момент стратегию MissedTickBehavior.

Задаёт используемую стратегию MissedTickBehavior.

Возвращает период интервала.

Возвращает аргумент без изменений.

Вызывает U::from(self).

Иными словами, это преобразование выполняет то, что выберет реализация From<T> for U.