Kingo.XxlJob.Core/src/DotXxlJob.Core/Hosted/JobExecuteHostedService.cs

using System.Threading;
using System.Threading.Tasks;
using Microsoft.Extensions.Hosting;

namespace DotXxlJob.Core
{
    /// <summary>
    ///  NOTE: 负责启动Executor服务，和进行服务注册的宿主服务
    /// </summary>
    public class JobsExecuteHostedService:BackgroundService 
    {
        private readonly IExecutorRegistry _registry;

        public JobsExecuteHostedService(IExecutorRegistry registry)
        {
            this._registry = registry;
        }

        protected override Task ExecuteAsync(CancellationToken stoppingToken)
        {
            return this._registry.RegistryAsync(stoppingToken);
        }
      
    }
}