Falcon/Falcon.SugarApi
1
0
Fork 1
Code Issues34 Pull Requests Projects Releases Wiki Activity

TimedTask使用进准的计时器方式而非轮训方式。

Browse Source
This commit is contained in:
Falcon 2025-03-06 14:38:16 +08:00
parent 7350a60bb2
commit 2fec21a3ea
1 changed files with 23 additions and 55 deletions

78
Falcon.SugarApi/TimedTask/TimedTask.cs
View File

@ -10,16 +10,12 @@ namespace Falcon.SugarApi.TimedTask
/// <summary>
/// 由定时器驱动的后台任务
/// </summary>
public abstract class TimedTask:BackgroundService, IDisposable
public abstract class TimedTask:BackgroundService
{
/// <summary>
/// 日志记录器
/// </summary>
protected readonly ILogger? Logger;
/// <summary>
/// 心跳计时器
/// </summary>
private readonly PeriodicTimer _timer;
/// <summary>
/// 运行一次任务
@ -34,20 +30,11 @@ namespace Falcon.SugarApi.TimedTask
/// </summary>
protected abstract string CronSchedule { get; }
/// <summary>
/// Timer心跳 毫秒
/// </summary>
public virtual int Heartbeat { get; protected set; } = 1000;
/// <summary>
/// 获取下次执行任务的计划
/// </summary>
protected CronExpression Schedule { get; private set; }
/// <summary>
/// 任务正在运行
/// </summary>
private bool _isRunning = false;
/// <summary>
/// 下次执行时间
/// </summary>
@ -83,10 +70,6 @@ namespace Falcon.SugarApi.TimedTask
/// 系统服务
/// </summary>
public IServiceProvider Service { get; set; }
/// <summary>
/// 资源锁
/// </summary>
private static object _lock = new object();
/// <summary>
/// 构造Timed后台任务
@ -95,7 +78,6 @@ namespace Falcon.SugarApi.TimedTask
public TimedTask(IServiceProvider service) {
this.Service = service;
this.Logger = service.GetService(typeof(ILogger<>).MakeGenericType(GetType())) as ILogger;
_timer = new PeriodicTimer(TimeSpan.FromMilliseconds(this.Heartbeat));
this.Schedule = new CronExpression(this.CronSchedule);
}
@ -108,49 +90,35 @@ namespace Falcon.SugarApi.TimedTask
if(!this.OnStart(this,stoppingToken)) {
return;
}
while(await _timer.WaitForNextTickAsync(stoppingToken)) {
lock(_lock) {
try {
while(!stoppingToken.IsCancellationRequested) {
DateTime nextRunTime = Schedule.GetNextOccurrence(DateTime.Now);
TimeSpan delay = nextRunTime - DateTime.Now;
if(delay > TimeSpan.Zero) {
await Task.Delay(delay,stoppingToken);
}
if(stoppingToken.IsCancellationRequested) {
break;
}
if(this._isRunning) {
continue;
// 执行任务
try {
var goOn = await this.Run(stoppingToken);
var comResult = this.OnCompleted(this,stoppingToken);
if(!goOn || !comResult) {
break;
}
}
if(DateTime.Now < this.NextTickTime) {
continue;
catch(Exception ex) {
if(!this.OnException(this,ex,stoppingToken)) {
break;
}
}
this._isRunning = true;
//Schedule = new CronExpression(this.CronSchedule);
}
try {
var goOn = await this.Run(stoppingToken);
var comResult = this.OnCompleted(this,stoppingToken);
if(!goOn || !comResult) {
break;
}
}
catch(Exception ex) {
if(!this.OnException(this,ex,stoppingToken)) {
break;
}
}
SetNextTick();
this._isRunning = false;
}
this.OnStop(this,stoppingToken);
}
private void SetNextTick(string? cronSchedule = null) {
var s = cronSchedule == null ? this.Schedule : new CronExpression(cronSchedule);
this.NextTickTime = s.GetNextOccurrence(DateTime.Now);
}
/// <summary>
/// 释放对象
/// </summary>
public override void Dispose() {
this._timer?.Dispose();
GC.SuppressFinalize(this);
base.Dispose();
finally {
this.OnStop(this,stoppingToken);
}
}
}
}