1234567891011121314151617181920212223242526272829303132333435363738394041424344454647 |
- using Admin.Core.Common.Helpers;
- using Microsoft.Extensions.Hosting;
- using System;
- using System.Threading;
- using System.Threading.Tasks;
- namespace Admin.Core.Tasks
- {
- public class Job1TimedService : IHostedService, IDisposable
- {
- private Timer _timer;
- // 这里可以注入
- public Job1TimedService()
- {
- }
- public Task StartAsync(CancellationToken cancellationToken)
- {
- Console.WriteLine("Job 1 is starting.");
- _timer = new Timer(DoWork, null, TimeSpan.Zero,
- TimeSpan.FromSeconds(60*60));//一个小时
- return Task.CompletedTask;
- }
- private void DoWork(object state)
- {
- ConsoleHelper.WriteSuccessLine($"Job 1: {DateTime.Now}");
- }
- public Task StopAsync(CancellationToken cancellationToken)
- {
- Console.WriteLine("Job 1 is stopping.");
- _timer?.Change(Timeout.Infinite, 0);
- return Task.CompletedTask;
- }
- public void Dispose()
- {
- _timer?.Dispose();
- }
- }
- }
|