rust学习-tokio::time

示例

use std::time::Duration;
use tokio::{task, time::interval};#[tokio::main]
async fn main() {let mut interval = interval(Duration::from_secs(1));let handle = task::spawn(async move {loop {interval.tick().await;println!("tick");}});handle.await.unwrap();
}

interval和sleep的区别

tick周期大于异步任务周期

use tokio::time;
use chrono::{DateTime, Local};async fn task_that_takes_a_second() {let now: DateTime<Local> = Local::now();println!("Current task time before is: {}", now.format("%Y-%m-%d %H:%M:%S"));time::sleep(time::Duration::from_secs(2)).await;let now: DateTime<Local> = Local::now();println!("Current task time after is: {}", now.format("%Y-%m-%d %H:%M:%S"));
}#[tokio::main]
async fn main() {let mut interval = time::interval(time::Duration::from_secs(3));for _i in 0..5 {let now: DateTime<Local> = Local::now();println!("Current main time before is: {}", now.format("%Y-%m-%d %H:%M:%S"));interval.tick().await;let now: DateTime<Local> = Local::now();println!("Current main time mid is: {}", now.format("%Y-%m-%d %H:%M:%S"));task_that_takes_a_second().await;let now: DateTime<Local> = Local::now();println!("Current main time after is: {}", now.format("%Y-%m-%d %H:%M:%S"));}
}

Current main time before is: 2023-08-11 13:46:48
Current main time mid is: 2023-08-11 13:46:48 // 第一次，立即触发
Current task time before is: 2023-08-11 13:46:48
Current task time after is: 2023-08-11 13:46:50
Current main time after is: 2023-08-11 13:46:50Current main time before is: 2023-08-11 13:46:50
Current main time mid is: 2023-08-11 13:46:51 // 距离上一次3秒
Current task time before is: 2023-08-11 13:46:51
Current task time after is: 2023-08-11 13:46:53
Current main time after is: 2023-08-11 13:46:53Current main time before is: 2023-08-11 13:46:53
Current main time mid is: 2023-08-11 13:46:54 // 距离上一次3秒
Current task time before is: 2023-08-11 13:46:54
Current task time after is: 2023-08-11 13:46:56
Current main time after is: 2023-08-11 13:46:56Current main time before is: 2023-08-11 13:46:56
Current main time mid is: 2023-08-11 13:46:57  // 距离上一次3秒
Current task time before is: 2023-08-11 13:46:57
Current task time after is: 2023-08-11 13:46:59
Current main time after is: 2023-08-11 13:46:59Current main time before is: 2023-08-11 13:46:59
Current main time mid is: 2023-08-11 13:47:00 // 距离上一次3秒
Current task time before is: 2023-08-11 13:47:00
Current task time after is: 2023-08-11 13:47:02
Current main time after is: 2023-08-11 13:47:02

tick周期小于异步任务周期

use tokio::time;
use chrono::{DateTime, Local};async fn task_that_takes_a_second() {let now: DateTime<Local> = Local::now();println!("Current task time before is: {}", now.format("%Y-%m-%d %H:%M:%S"));time::sleep(time::Duration::from_secs(5)).await;let now: DateTime<Local> = Local::now();println!("Current task time after is: {}", now.format("%Y-%m-%d %H:%M:%S"));
}#[tokio::main]
async fn main() {let mut interval = time::interval(time::Duration::from_secs(3));for _i in 0..5 {let now: DateTime<Local> = Local::now();println!("Current main time before is: {}", now.format("%Y-%m-%d %H:%M:%S"));interval.tick().await;let now: DateTime<Local> = Local::now();println!("Current main time mid is: {}", now.format("%Y-%m-%d %H:%M:%S"));task_that_takes_a_second().await;let now: DateTime<Local> = Local::now();println!("Current main time after is: {}", now.format("%Y-%m-%d %H:%M:%S"));}
}

Current main time before is: 2023-08-11 13:51:24
Current main time mid is: 2023-08-11 13:51:24
Current task time before is: 2023-08-11 13:51:24
Current task time after is: 2023-08-11 13:51:29
Current main time after is: 2023-08-11 13:51:29Current main time before is: 2023-08-11 13:51:29
Current main time mid is: 2023-08-11 13:51:29 // 举例上一次超过3秒
Current task time before is: 2023-08-11 13:51:29
Current task time after is: 2023-08-11 13:51:34
Current main time after is: 2023-08-11 13:51:34Current main time before is: 2023-08-11 13:51:34
Current main time mid is: 2023-08-11 13:51:34  // 举例上一次超过3秒
Current task time before is: 2023-08-11 13:51:34
Current task time after is: 2023-08-11 13:51:39
Current main time after is: 2023-08-11 13:51:39Current main time before is: 2023-08-11 13:51:39
Current main time mid is: 2023-08-11 13:51:39  // 举例上一次超过3秒
Current task time before is: 2023-08-11 13:51:39
Current task time after is: 2023-08-11 13:51:44
Current main time after is: 2023-08-11 13:51:44Current main time before is: 2023-08-11 13:51:44
Current main time mid is: 2023-08-11 13:51:44  // 举例上一次超过3秒
Current task time before is: 2023-08-11 13:51:44
Current task time after is: 2023-08-11 13:51:49
Current main time after is: 2023-08-11 13:51:49

timeout

use tokio::time::{timeout, Duration};
use tokio::time;
use chrono::{DateTime, Local};async fn long_future() {let now: DateTime<Local> = Local::now();println!("Current task time before is: {}", now.format("%Y-%m-%d %H:%M:%S"));time::sleep(time::Duration::from_secs(5)).await;let now: DateTime<Local> = Local::now();println!("Current task time after is: {}", now.format("%Y-%m-%d %H:%M:%S"));
}#[tokio::main]
async fn main() {for _i in 0..5 {let now: DateTime<Local> = Local::now();println!("Current main time before is: {}", now.format("%Y-%m-%d %H:%M:%S"));let res = timeout(Duration::from_secs(1), long_future()).await;let now: DateTime<Local> = Local::now();println!("Current main time after is: {}", now.format("%Y-%m-%d %H:%M:%S"));if res.is_err() {println!("operation timed out");}}
}

interval_at

pub fn interval_at(start: Instant, period: Duration) -> Interval

use tokio::time::{interval_at, Duration, Instant};
use chrono::{DateTime, Local};#[tokio::main]
async fn main() {let start = Instant::now() + Duration::from_secs(5);let mut interval = interval_at(start, Duration::from_secs(3)); // 不会立即开始let now: DateTime<Local> = Local::now();println!("Current task time now is: {}", now.format("%Y-%m-%d %H:%M:%S"));interval.tick().await; // ticks after 3slet now: DateTime<Local> = Local::now();println!("Current task time now is: {}", now.format("%Y-%m-%d %H:%M:%S"));interval.tick().await; // ticks after 3slet now: DateTime<Local> = Local::now();println!("Current task time now is: {}", now.format("%Y-%m-%d %H:%M:%S"));interval.tick().await; // ticks after 3slet now: DateTime<Local> = Local::now();println!("Current task time now is: {}", now.format("%Y-%m-%d %H:%M:%S"));
}

Current task time now is: 2023-08-11 19:34:30
Current task time now is: 2023-08-11 19:34:35
Current task time now is: 2023-08-11 19:34:38
Current task time now is: 2023-08-11 19:34:41

MissedTickBehavior

use tokio::time;
use chrono::{DateTime, Local};
use tokio::time::MissedTickBehavior;async fn task_that_takes_a_second() {let now: DateTime<Local> = Local::now();println!("Current task time before is: {}", now.format("%Y-%m-%d %H:%M:%S"));time::sleep(time::Duration::from_secs(5)).await;let now: DateTime<Local> = Local::now();println!("Current task time after is: {}", now.format("%Y-%m-%d %H:%M:%S"));
}#[tokio::main]
async fn main() {let mut interval = time::interval(time::Duration::from_secs(3));interval.set_missed_tick_behavior(MissedTickBehavior::Delay);for _i in 0..5 {let now: DateTime<Local> = Local::now();println!("Current main time before is: {}", now.format("%Y-%m-%d %H:%M:%S"));interval.tick().await;let now: DateTime<Local> = Local::now();println!("Current main time mid is: {}", now.format("%Y-%m-%d %H:%M:%S"));task_that_takes_a_second().await;let now: DateTime<Local> = Local::now();println!("Current main time after is: {}", now.format("%Y-%m-%d %H:%M:%S"));}
}

在 Rust 的 tokio 库中，MissedTickBehavior 是一个枚举类型，表示当 Interval 频率计时器在某个周期中错过某个间隔时如何处理。具体来说，它有以下三个变体：

  • Burst：表示如果错过计时间隔，则会立即执行多个周期，直到被重新赶上。
  • Delay：表示如果错过计时间隔，则在下一个可用的计时间隔时执行周期。
  • Skip：表示如果错过计时间隔，则跳过它并继续执行下一个计时间隔的周期。
    一般情况下， Burst 和 Delay 会导致执行速率加速，Skip 会导致执行速率降低但保证数据与频率同步。
#[tokio::main]
async fn main() {let mut interval_burst = time::interval(Duration::from_millis(5));interval_burst.set_missed_tick_behavior(time::MissedTickBehavior::Burst);let mut interval_delay = time::interval(Duration::from_millis(5));interval_delay.set_missed_tick_behavior(time::MissedTickBehavior::Delay);let mut count_burst = 0;let mut count_delay = 0;// 运行到20000次以上才会看出差异loop {select! {_ = interval_burst.tick() => {count_burst += 1;println!("Burst: tick #{}", count_burst);}_ = interval_delay.tick() => {count_delay += 1;println!("Delay: tick #{}", count_delay);}}}
}

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/news/37657.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

【大数据】一些基本概念

【大数据】一些基本概念

一、数据库、数据仓库、数据湖 1.什么是数据库 (Database, DB) 数据库是指长期储存在计算机中的有组织的, 可共享的数据集合 就是存储数据的仓库 数据库有三个特点: 永久存储, 有组织, 可共享 数据库是一种结构化数据存储技术&#xff0c;用于存储和管理有组织的数据。数据库…
阅读更多...
微信小程序云开发快速入门（2/4）

微信小程序云开发快速入门（2/4）

前言 我们对《微信小程序云开发快速入门&#xff08;1/4&#xff09;》的知识进行回顾一下。在上章节我们知道了云开发的优势以及能力&#xff0c;并且我们还完成了码仔备忘录的本地版到网络版的改造&#xff0c;主要学习了云数据库同时还通过在小程序使用云API直接操作了云数…
阅读更多...
SciencePub学术| 智能计量类重点SCIE征稿中

SciencePub学术| 智能计量类重点SCIE征稿中

SciencePub学术 刊源推荐: 智能计量类重点SCIE征稿中&#xff01;信息如下&#xff0c;录满为止&#xff1a; 一、期刊概况&#xff1a; 智能计量类重点SCIE 【期刊简介】IF&#xff1a;2.0-2.5&#xff0c;JCR3区&#xff0c;中科院4区&#xff1b; 【版面类型】正刊&#…
阅读更多...
new BigDecimal(double val)注意事项 / JWT解析BigDecimal类型数据

new BigDecimal(double val)注意事项 / JWT解析BigDecimal类型数据

前言&#xff1a; 公司项目中有一个板块需要解析JWT令牌获取载荷里面封装的数据&#xff0c;遇到要解析一个BigDecimal类型的数据 问题发现过程&#xff1a; 正常来说&#xff0c;我们解析一个JWT令牌的步骤如下&#xff1a; public static Claims getDataFromToken(String tok…
阅读更多...
极狐GitLab 企业级 CI/CD 规模化落地实践指南（一）

极狐GitLab 企业级 CI/CD 规模化落地实践指南（一）

目录 template 引用&#xff0c;减少代码冗余&#xff0c;增强 CI/CD 构建扩展性 问题 1&#xff1a;代码冗余&#xff0c;低效实践 问题 2&#xff1a;维护性难&#xff0c;工作量大 ➤ local ➤ file ➤ remote ➤ template 收益 1&#xff1a;一处修改&#xff0c;多…
阅读更多...
TIOBE2023年8月榜单发布，Python超越老将C/C++蝉联冠军

TIOBE2023年8月榜单发布，Python超越老将C/C++蝉联冠军

TIOBE 编程社区指数是一个衡量编程语言受欢迎程度的指标&#xff0c;评判的依据来自世界范围内的工程师、课程、供应商及搜索引擎&#xff0c;TIOBE 官网近日公布了 2023 年 8 月的编程语言排行榜。 此次的榜单中&#xff0c;Python依旧稳居第一&#xff0c;占比达到了13.33%。…
阅读更多...
jpg图片太大怎么压缩？这样做轻松压缩图片

jpg图片太大怎么压缩？这样做轻松压缩图片

图片太大会给存储、分享带来麻烦&#xff0c;但其实现在压缩图片大小也不是什么难事&#xff0c;下面就给大家分享几个一直用的图片压缩方法&#xff0c;包含批量压缩、在线压缩、免费压缩等多种方式&#xff0c;大家按需自取哈~ 方法一&#xff1a;嗨格式压缩大师 这是一个可…
阅读更多...
Kotlin Executors线程池newSingleThreadExecutor单线程

Kotlin Executors线程池newSingleThreadExecutor单线程

Kotlin Executors线程池newSingleThreadExecutor单线程 import java.util.concurrent.Executorsfun main() {val mExecutorService Executors.newSingleThreadExecutor()for (i in 1..5) {mExecutorService.execute {println("seq-$i tid:${Thread.currentThread().threa…
阅读更多...
typeScript 之 基础

typeScript 之 基础

工具: PlayGround 源码&#xff1a; GitHub TypeScript 变量声明 typeScript中变量声明注意&#xff1a; 开头不能以数字开头变量名称可以包含数字和字母除了下划线_和美元$符号外&#xff0c;不能包含其他任意特殊字符 声明的结构&#xff1a; let 变量名&#xff1a; 类型…
阅读更多...
面试经典150题——罗马数字转整数

面试经典150题——罗马数字转整数

罗马数字包含以下七种字符: I&#xff0c; V&#xff0c; X&#xff0c; L&#xff0c;C&#xff0c;D 和 M。 字符 数值 I 1 V 5 X 10 L 50 C 100 D 500 M 1000 例如&#x…
阅读更多...
docker 学习-- 01 基础知识

docker 学习-- 01 基础知识

docker 学习-- 01 基础知识 文章目录 docker 学习-- 01 基础知识1.前言1.1 docker 是什么1.2 docker优点1.2.1 统一开发和生产环境:1.2.2 高性能:1.2.3 更轻松的维护和拓展&#xff1a;1.2.4 更轻松的迁移&#xff1a; 1.3 docker缺点1.3.1 运行环境受限1.3.2 文件管理和网络端…
阅读更多...
item_sku-获取sku详细信息

item_sku-获取sku详细信息

一、接口参数说明&#xff1a; item_sku-获取sku详细信息&#xff0c;点击更多API调试&#xff0c;请移步注册API账号点击获取测试key和secret 公共参数 请求地址: https://api-gw.onebound.cn/taobao/item_sku 名称类型必须描述keyString是调用key&#xff08;点击获取测试…
阅读更多...
安全中间件的设计思路和简单实践

安全中间件的设计思路和简单实践

rasp 的侵入式特性和拦截特性导致开发和运维普通不太愿意配合&#xff0c;当生产环境出现问题时往往第一时间先把责任推给 rasp&#xff0c;逐渐的安全部门普遍只能把 rasp 设置为告警模式&#xff0c;而且越是大的集群拦截开的就越少&#xff0c;所以字节的 elkeid 和某外卖大…
阅读更多...
P13-CNN学习1.3-ResNet(神之一手~)

P13-CNN学习1.3-ResNet(神之一手~)

论文地址:CVPR 2016 Open Access Repository https://arxiv.org/pdf/1512.03385.pdf Abstract 翻译 深层的神经网络越来越难以训练。我们提供了一个残差学习框架用来训练那些非常深的神经网络。我们重新定义了网络的学习方式&#xff0c;让网络可以直接学习输入信息与输出信息…
阅读更多...
Python-OpenCV中的图像处理-图像直方图

Python-OpenCV中的图像处理-图像直方图

Python-OpenCV中的图像处理-图像直方图 图像直方图统计直方图绘制直方图Matplotlib绘制灰度直方图Matplotlib绘制RGB直方图 使用掩膜统计直方图直方图均衡化Numpy图像直方图均衡化OpenCV中的直方图均衡化CLAHE 有限对比适应性直方图均衡化 2D直方图OpenCV中的2D直方图Numpy中2D…
阅读更多...
代码随想录算法训练营20期|第七天|哈希表part02|454.四数相加II ● 383. 赎金信 ● 15. 三数之和 ● 18. 四数之和 ● 总结

代码随想录算法训练营20期|第七天|哈希表part02|454.四数相加II ● 383. 赎金信 ● 15. 三数之和 ● 18. 四数之和 ● 总结

454.四数相加II 比较巧思的解法&#xff0c;先把nums1 和nums2的数两两相加&#xff0c;并存储sum和次数 再在nums3和nums4里找对应和sum和为0的数值i,j Time: N^2 Space:N^2, 最坏情况下A和B的值各不相同&#xff0c;相加产生的数字个数为 n^2 class Solution {public int fo…
阅读更多...
Spring AOP实践：如何通过aop记录日志？

Spring AOP实践：如何通过aop记录日志？

目录 一、依赖 二、自定义注解 三、切面 一、依赖 以SpringBoot工程为例&#xff0c;导入aop的依赖。 <dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-aop</artifactId> </dependency> 二…
阅读更多...
为什么要自动化Web测试？

为什么要自动化Web测试？

Web自动化是更快地实现所需结果的较佳方式。自动化测试在市场上引起了巨大的轰动。此软件测试过程可以让您使用正确的自动化测试工具和技术集自动执行测试过程。我们执行它是为了检查软件应用程序是否具有完全按照我们希望它执行的方式执行的勇气。 比以往更快地获得反馈 自动化…
阅读更多...
基于Promise.resolve实现Koa请求队列中间件

基于Promise.resolve实现Koa请求队列中间件

本文作者为360奇舞团前端工程师 前言 最近在做一个 AIGC 项目&#xff0c;后端基于 Koa2 实现。其中有一个需求就是调用兄弟业务线服务端 AIGC 能力生成图片。但由于目前兄弟业务线的 AIGC 项目也是处于测试阶段&#xff0c;能够提供的服务器资源有限&#xff0c;当并发请求资源…
阅读更多...
kafka和rabbitmq之间的区别以及适用场景

kafka和rabbitmq之间的区别以及适用场景

Kafka 和 RabbitMQ 都是流行的消息传递系统&#xff0c;用于实现分布式系统中的消息传递、事件处理和数据流。它们在设计和适用场景上有一些不同&#xff0c;下面详细介绍它们之间的区别和适用场景。 Kafka 特点和优势&#xff1a; 高吞吐量&#xff1a; Kafka 的设计目标是实…
阅读更多...
最新文章

Copyright @ 2022~2023