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

后台任务异步化

Browse Source
This commit is contained in:
falcon 2022-04-01 15:52:10 +08:00
parent 3333e7f12c
commit 4077501379
2 changed files with 11 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
Falcon.SugarApi.Test/BackTaskTest.cs
View File

@ -28,23 +28,23 @@ namespace Falcon.SugarApi.Test
var asyncTask = new BackTaskAsync(); var asyncTask = new BackTaskAsync();
Console.WriteLine("启动异步任务"); Console.WriteLine("启动异步任务");
asyncTask.StartAsync(token.Token).Wait(); asyncTask.StartAsync(token.Token).Wait();
Thread.Sleep(5 * 1000); Thread.Sleep(10 * 1000);
Console.WriteLine("停止异步任务"); Console.WriteLine("停止异步任务");
asyncTask.StopAsync(token.Token).Wait(); asyncTask.StopAsync(token.Token).Wait();
} }
} }
public class BackTaskAsync : BackgroundLongTask public class BackTaskAsync : BackTaskObject
{ {
public BackTaskAsync() { public BackTaskAsync() {
this.Log = new TestLog<BackTaskObject>(); this.Log = new TestLog<BackTaskObject>();
} }
public ILogger Log { get; set; }
public override float RunTimespan => 1; public override float RunTimespan => 1;
protected async override void Run() { protected async override Task RunAsync() {
this.Log.LogInformation($"{DateTime.Now.ToString("HH:mm:ss")}:BackTaskAsync Run!"); this.Log.LogInformation($"{DateTime.Now.ToString("HH:mm:ss")}:BackTaskAsync Run!");
//Thread.Sleep(3 * 1000);
await Task.Delay(new TimeSpan(0,0,3));
await Task.CompletedTask; await Task.CompletedTask;
} }
} }
@ -76,8 +76,9 @@ namespace Falcon.SugarApi.Test
base.OnCompleted(t); base.OnCompleted(t);
} }
protected override void Run() { protected override Task RunAsync() {
this.Log.LogInformation($"{DateTime.Now.ToString("HH:mm:ss")}:Test Run!"); this.Log.LogInformation($"{DateTime.Now.ToString("HH:mm:ss")}:Test Run!");
return Task.CompletedTask;
} }
} }

7
Falcon.SugarApi/BackTask/BackgroundLongTask.cs
View File

@ -13,9 +13,9 @@ namespace Falcon.SugarApi.BackTask
/// <summary> /// <summary>
/// 要执行的任务 /// 要执行的任务
/// </summary> /// </summary>
protected abstract void Run(); protected abstract Task RunAsync();
/// <summary> /// <summary>
/// 执行时间间隔 /// 执行时间间隔,秒
/// </summary> /// </summary>
public abstract float RunTimespan { get; } public abstract float RunTimespan { get; }
/// <summary> /// <summary>
@ -46,7 +46,8 @@ namespace Falcon.SugarApi.BackTask
OnStart(this); OnStart(this);
while (!TokenSource.Token.IsCancellationRequested) { while (!TokenSource.Token.IsCancellationRequested) {
await Task.Delay(TimeSpan.FromSeconds(RunTimespan)) await Task.Delay(TimeSpan.FromSeconds(RunTimespan))
.ContinueWith(wt => { Run(); }).ContinueWith(wt => OnCompleted(this)); .ContinueWith(_ => { RunAsync().Wait(); })
.ContinueWith(_ => OnCompleted(this));
} }
OnStop(this); OnStop(this);
}; };