.NET 6 新特性 PeriodicTimer

.NET 6 新特性 PeriodicTimer

Intro

.NET 6 中引入了一个新的 Timer ——  System.Threading.PeriodicTimer,和之前的几个 Timer 相比一个最大的区别就是,新的 PeriodicTimer 的事件处理可以比较方便地使用异步方式,消除了使用 callback 的机制,减少了使用的复杂度。

Sample

来看一个使用示例:

using var cts = new CancellationTokenSource();
Console.CancelKeyPress += (sender, e) =>
{e.Cancel = true;cts.Cancel();
};using var timer = new PeriodicTimer(TimeSpan.FromSeconds(3));
try
{while (await timer.WaitForNextTickAsync(cts.Token)){Console.WriteLine($"Timed event triggered({DateTime.Now:HH:mm:ss})");}
}
catch (OperationCanceledException)
{Console.WriteLine("Operation cancelled");
}

通常 PeriodicTimer 可以结合 CancellationToken 一起使用,和 CancellationToken 一起用的时候需要注意,如果 cancellationToken 被取消的时候会抛出一个 OperationCanceledException 需要考虑自己处理异常

除此之外如果 PeriodicTimerDispose,这个 timer 就相当于是失效的,并且无法重新恢复,来看下面这个示例:

var timer1 = new PeriodicTimer(TimeSpan.FromSeconds(2));
timer1.Dispose();
if (await timer1.WaitForNextTickAsync())
{Console.WriteLine("Timer1 event triggered");
}

上面这样的一段代码,在 WaitForNextTickAsync 之前就已经调用了 Dispose(),此时 WaitForNextTickAsync 方法会始终返回 false ,所以 Console.WriteLine 的逻辑也不会被执行

我们之前会尝试使用 Timer 来做一些后台任务,可以改造成使用新的 PeriodicTimer 来实现,小示例如下:

public abstract class TimerScheduledService : BackgroundService
{private readonly PeriodicTimer _timer;private readonly TimeSpan _period;protected readonly ILogger Logger;protected TimerScheduledService(TimeSpan period, ILogger logger){Logger = logger;_period = period;_timer = new PeriodicTimer(_period);}protected override async Task ExecuteAsync(CancellationToken stoppingToken){try{while (await _timer.WaitForNextTickAsync(stoppingToken)){try{Logger.LogInformation("Begin execute service");await ExecuteInternal(stoppingToken);}catch (Exception ex){Logger.LogError(ex, "Execute exception");}finally{Logger.LogInformation("Execute finished");}}}catch (OperationCanceledException operationCancelledException){Logger.LogWarning(operationCancelledException, "service stopped");}}protected abstract Task ExecuteInternal(CancellationToken stoppingToken);public override Task StopAsync(CancellationToken cancellationToken){Logger.LogInformation("Service is stopping.");_timer.Dispose();return base.StopAsync(cancellationToken);}
}

实现示例如下:

public class TimedHealthCheckService : TimerScheduledService
{public TimedHealthCheckService(ILogger<TimedHealthCheckService> logger) : base(TimeSpan.FromSeconds(5), logger){}protected override Task ExecuteInternal(CancellationToken stoppingToken){Logger.LogInformation("Executing...");return Task.CompletedTask;}
}

运行输出如下:

68af252b8b1a5ad5adec834db6c01d4d.png

logging output

More

新的 PeriodicTimer 相比之前的几个 Timer 来说,有下面几个特点

  • 没有 callback 来绑定事件

  • 不会发生重入,只允许有一个消费者,不允许同一个 PeriodicTimer 在不同的地方同时 WaitForNextTickAsync,不需要自己做排他锁来实现不能重入

  • 异步化,之前的几个 timer 的 callback 都是同步的,使用新的 timer 我们可以更好的使用异步方法,避免写 Sync over Async 之类的代码

  • Dispose() 之后,该实例就无法再使用,WaitForNextTickAsync 始终返回 false

最后来做一个题目,把第一个示例改造一下,最终代码如下:

using var cts = new CancellationTokenSource();
cts.CancelAfter(TimeSpan.FromSeconds(30));
using var timer = new PeriodicTimer(TimeSpan.FromSeconds(3));
try
{while (await timer.WaitForNextTickAsync(cts.Token)){await Task.Delay(5000);Console.WriteLine($"Timed event triggered({DateTime.Now:HH:mm:ss})");}
}
catch (OperationCanceledException)
{Console.WriteLine("Operation cancelled");
}

猜一下输出结果是什么,Timed event triggered 会输出几次

e8cc5202cbc7c009191ff2a3ec9150c4.png

References

  • https://www.ilkayilknur.com/a-new-modern-timer-api-in-dotnet-6-periodictimer

  • https://docs.microsoft.com/en-us/dotnet/api/system.threading.periodictimer?view=net-6.0

  • https://github.com/dotnet/runtime/blob/v6.0.0/src/libraries/System.Private.CoreLib/src/System/Threading/PeriodicTimer.cs

  • https://github.com/dotnet/runtime/issues/31525

  • https://github.com/WeihanLi/SamplesInPractice/blob/master/net6sample/PeriodicTimerSample/Program.cs

  • https://github.com/OpenReservation/ReservationServer/blob/dev/OpenReservation.Helper/Services/CronScheduleServiceBase.cs#L91

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

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

相关文章

Android之基于xmpp openfire smack开发之smack类库介绍和使用[2]

http://blog.csdn.net/shimiso/article/details/8816540 关于Smack编程库&#xff0c;前面我们提到&#xff0c;它是面向Java端的api&#xff0c;主要在PC上使用&#xff0c;利用它我们可以向openfire服务器注册用户&#xff0c;发送消息&#xff0c;并且可以通过监听器获得此…

团队介绍

团队成员&#xff1a;孙哲&#xff0c;何琳琳&#xff0c;张一博&#xff0c;李营成员特点&#xff1a;孙哲&#xff1a;我们组的核心力量&#xff0c;擅长编程&#xff0c;对C&#xff0c;Java都有很好的掌握&#xff0c;何琳琳&#xff1a;热爱学习&#xff0c;积极向上&…

简单明了区分escape、encodeURI和encodeURIComponent

一、前言 讲这3个方法区别的文章太多了&#xff0c;但是大部分写的都很绕。本文试图从实践角度去讲这3个方法。 二、escape和它们不是同一类 简单来说&#xff0c;escape是对字符串(string)进行编码(而另外两种是对URL)&#xff0c;作用是让它们在所有电脑上可读。编码之后的效…

python 线程 的类库_python类库32[多线程]

一 python 多线程因为CPython的实现使用了Global Interpereter Lock(GIL)&#xff0c;使得python中同一时刻只有一个线程在执行&#xff0c;从而简化了python解释器的实现&#xff0c;且python对象模型天然地线程安全。如果你想你的应用程序在多核的机器上使用更好的资源&#…

SQL Server 排序规则(摘)

3Sql Server数据库&#xff0c;在跨库多表连接查询时&#xff0c;若两数据库默认字符集不同&#xff0c;系统就会返回这样的错误&#xff1a;“无法解决equal to操作的排序规则冲突” 一、错误分析&#xff1a; 这个错误是因为排序规则不一致造成的&#xff0c;比如&#xff1…

当.NET遇到机器学习

微软中国MSDN 点击上方蓝字关注我们ML.NET 是面向 .NET 开发人员的开源跨平台机器学习框架&#xff0c;你可以使用 C# 或 F# 创建自定义 ML 模型&#xff0c;而无需离开.NET 生态系统。ML.NET 使你能够在联机或脱机场景中将机器学习添加到 .NET 应用程序中。借助此功能&#x…

当你和你女朋友闹矛盾时......

1 听起来是这么个道理&#xff08;素材来源网络&#xff0c;侵删&#xff09;▼2 真的是非常专一了&#xff08;via.皎皎月当楼&#xff09;▼3 给朋友定做的蛋糕&#xff08;素材来源网络&#xff0c;侵删&#xff09;▼4 当你和女朋友闹矛盾时▼5 师范的男孩子有多害怕&a…

Android之基于xmpp openfire smack开发之Android客户端开发[3]

http://blog.csdn.net/shimiso/article/details/11225873 在上两篇文章中&#xff0c;我们依次介绍openfire部署以及smack常用API的使用&#xff0c;这一节中我们着力介绍如何基于asmack开发一个Android的客户端&#xff0c;本篇的重点在实践&#xff0c;讲解和原理环节&#…

imx6 i2c分析

本文主要分析&#xff1a;      1. i2c设备注册      2. i2c驱动注册      3. 上层调用过程参考&#xff1a;  http://www.cnblogs.com/helloworldtoyou/p/5126618.html1. i2c设备注册 kernel/arch/arm/mach-mx6/board-mx6q_sabresd.c …

Java原来如此-随机数

在Java中&#xff0c;生成随机数有两种方法。1是使用Random类。2是使用Math类中的random方法。 我们现在做个例子&#xff0c;比如生成20个0到10之间的随机数。 1.使用Random类的nextInt(n)方法&#xff0c;n代表0到n之间&#xff0c;包括0&#xff0c;不包括n。 Random random…

python列表双中括号_python – Pandas中双括号`[[…]]`和单括号`[....

考虑一下: 来源DF: In [79]: df Out[79]: Brains Bodies 0 42 34 1 32 23 选择一列 – 导致Pandas.Series: In [80]: df[Brains] Out[80]: 0 42 1 32 Name: Brains, dtype: int64 In [81]: type(df[Brains]) Out[81]: pandas.core.series.Series 选择DataFrame的子集 – 导致…

TableView详解

&#xff0d;、建立 UITableView DataTable [[UITableView alloc] initWithFrame:CGRectMake(0, 0, 320, 420)]; [DataTable setDelegate:self]; [DataTable setDataSource:self]; [self.view addSubview:DataTable]; [DataTable release]; 二、UITableView各Method说明 //Sec…

PowerToys插件扩展(类似Alfred)

在mac系统除了自带的Spotlight还有一个很好用的工具叫Alfredimage在windows系统也有一个很好用的工具叫PowerToys&#xff0c;是微软的一个开源项目imagehttps://github.com/microsoft/PowerToys从上面的github地址可以下载安装包。image它有很多快捷功能&#xff0c;请大家自己…

Android之基于xmpp openfire smack开发之Android消息推送技术原理分析和实践[4]

http://blog.csdn.net/shimiso/article/details/8156439 前面几篇给大家系统讲解的有关xmpp openfire smack asmack相关的技术和使用&#xff0c;大家如果有所遗忘可以参考 顺便也一起回顾下xmpp的历程 xmpp协议起源于著名的Linux即时通讯服务服务器jabber,有时候我们会把xmp…

12年前的高考到底有多难,只在这一道题上就看出来了...

▲ 点击查看2008年高考江西数学考卷的最后一题&#xff0c;说是高考史上最恐怖的数学题&#xff0c;应该没有异议。这道题到底有多难呢&#xff1f;最后这道压轴题一共是14分。考试结果出来&#xff0c;所有考生的平均分是0.31分。曾有一位同学这样介绍&#xff1a;“在我们学校…

Cypher查询语言--Neo4j-WHERE(三)

目录 WhereBoolean 操作类型节点属性上的过滤正则表达式转义正则表达式不分大小些正则表达式关系类型上的过滤属性存在性如果缺失属性默认为true如果缺失属性默认为false空置null过滤关系过滤Where 如果需要从查找的数据的图中过滤&#xff0c;可以在查询语句中添加where子句。…

12篇学通C#网络编程——第一篇 基础之进程线程

在C#的网络编程中&#xff0c;进程和线程是必备的基础知识&#xff0c;同时也是一个重点&#xff0c;所以我们要好好的掌握一下。 一&#xff1a;概念 首先我们要知道什么是”进程”&#xff0c;什么是“线程”&#xff0c;好&#xff0c;查一下baike。 进程&#xff1a;是一个…

建立学生选课表 mysql 语句_MySQL常用SQL语句(Python实现学生、课程、选课表增删改查)...

以基本的学生选课为例&#xff0c;建立选课数据库&#xff0c;学生、班级、选课信息三张表&#xff0c;并分别对表进行插删改操作&#xff1a;import MySQLdbtry:conn MySQLdb.connect(host localhost, user root, passwd root, db xuanke, port 3306)cur conn.cursor()…

加快网站访问速度--jquery.js

jquery现在是越来越大&#xff0c;网络加载速度上我们应该做到能省就省&#xff0c;毫无疑问google的服务器和cdn以及访问速度是非常快的&#xff0c;而且google敞开怀抱&#xff0c;提供各种代码库给我们下载调用。jquery就是其中一个。 在jquery官网有从google 微软microsoft…

Android之Google推荐的图片加载库Glide介绍

原文链接:Google推荐的图片加载库Glide介绍作者 : nuuneoi译者 : jianghejie校对者 :