记录Quarter的基本使用

2019-12-16 13:04:06 阅读：502 来源： 互联网

标签：基本 CancellationToken Task 记录 System scheduler using Quarter public

using Quartz;
using Quartz.Impl;
using Quartz.Impl.Matchers;
using Quartz.Logging;
using System;
using System.Collections.Generic;
using System.Collections.Specialized;
using System.Data.Entity.Migrations;
using System.Linq;
using System.Threading;
using System.Threading.Tasks;
using System.Transactions;
using System.Web;
using WebApplication3.Models;
using WebApplication3.Service;
 
namespace WebApplication3
{
    public static class QuartzHelper
    {
        public static async Task RunProgramRunExample()
        {
            try
            {
                // Grab the Scheduler instance from the Factory
                NameValueCollection props = new NameValueCollection
                {
                    { "quartz.serializer.type", "binary" }
                };
                StdSchedulerFactory factory = new StdSchedulerFactory(props);
                IScheduler scheduler = await factory.GetScheduler();
 
                // and start it off
                await scheduler.Start();
 
                // define the job and tie it to our HelloJob class
                IJobDetail job = JobBuilder.Create<HelloJob>()
                    .WithIdentity("job1", "group1")
                    .Build();
 
                // Trigger the job to run now, and then repeat every 10 seconds
                ITrigger trigger = TriggerBuilder.Create()
                    .WithIdentity("trigger1", "group1")
                    //将在以后的整点触发
                    .StartAt(DateBuilder.EvenHourDate(null))
                    //.StartAt(DateBuilder.FutureDate(1, IntervalUnit.Day))
                    //.StartNow()
                    //.WithSchedule(CronScheduleBuilder.DailyAtHourAndMinute(19, 36))//每天几点几分触发
                    .WithSimpleSchedule(x => x
                                               .WithIntervalInHours(1)//每1小时触发
                                                                      //.WithIntervalInMinutes(1)//每分钟
                                                                      //.WithIntervalInSeconds(10)
                        .RepeatForever())
                    .Build();
 
                ///监听任务
                //scheduler.ListenerManager.AddJobListener(new MyJobListener(), KeyMatcher<JobKey>.KeyEquals(new JobKey("job1", "group1")));
 
                scheduler.ListenerManager.AddJobListener(new MyJobListener(), GroupMatcher<JobKey>.AnyGroup());
 
                // Tell quartz to schedule the job using our trigger
                await scheduler.ScheduleJob(job, trigger);
 
                // and last shut down the scheduler when you are ready to close your program
                //await scheduler.Shutdown();
            }
            catch (SchedulerException se)
            {
                Console.WriteLine(se);
            }
        }
    }
    public class MyJobListener : IJobListener
    {
        public string Name
        {
            get
            {
                return "监听任务";
            }
        }
        public Task JobToBeExecuted(IJobExecutionContext context, CancellationToken cancellationToken = default(CancellationToken))
        {
            return Task.Run(() =>
            {
                JobToBeExecuted();
            });
        }
 
        public Task JobExecutionVetoed(IJobExecutionContext context, CancellationToken cancellationToken = default(CancellationToken))
        {
            return Task.Run(() =>
            {
                JobExecutionVetoed();
            });
        }
 
        public Task JobWasExecuted(IJobExecutionContext context, JobExecutionException jobException, CancellationToken cancellationToken = default(CancellationToken))
        {
            return Task.Run(() =>
             {
                 JobWasExecuted();
             });
        }
        /// <summary>
        /// 执行前
        /// </summary>
        public void JobToBeExecuted()
        {
        }
        /// <summary>
        /// 触发失效
        /// </summary>
        public void JobExecutionVetoed()
        {
            string path4 = System.AppDomain.CurrentDomain.BaseDirectory;
            new Common.CommonFun().WriteLog("位置：QuartzHelper,定时器触发失效！", "autoUpdate");
        }
        /// <summary>
        /// 触发完成
        /// </summary>
        public void JobWasExecuted()
        {
        }
    }
    /// <summary>
    /// 定时任务
    /// </summary>
    public class HelloJob : IJob
    {
        public async Task Execute(IJobExecutionContext context)
        {
            await Task.Run(() =>
            {
                   
            });
        }
    }
}

记录Quartz的基本使用

点赞
收藏
分享
- 文章举报

看月亮的向月葵发布了7 篇原创文章 · 获赞 2 · 访问量 6323 私信关注

标签：基本,CancellationToken,Task,记录,System,scheduler,using,Quarter,public
来源： https://www.cnblogs.com/lonelyxmas/p/12048544.html

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。

ICode9

记录Quarter的基本使用