[DisallowConcurrentExecution]public class JobWraper<TJob> : IJob where TJob : IJob, new(){private static int syncFlag = 0;private IJob jobInner = null;public JobWraper(){jobInner = Activator.CreateInstance<TJob>();}public void Execute(IJobExecutionContext context){if (Interlocked.Increment(ref syncFlag) != 1) return; //忙判断try{jobInner.Execute(context);}catch (Exception ex){Master.WriteMsg(context.JobDetail.Key + "执行异常：" + ex.Message + Environment.NewLine + ex.StackTrace, true, true);}Interlocked.Exchange(ref syncFlag, 0); //解除忙}

    public class JobManager{private IScheduler scheduler = null;private int schedulerState = 0;public Dictionary<string, JobWithTrigger> JobTriggers{get;private set;}private IScheduler GetAScheduler(){var stdSchedulerFactory = new StdSchedulerFactory();scheduler = stdSchedulerFactory.GetScheduler();return scheduler;}public JobManager(){scheduler = GetAScheduler();JobTriggers = new Dictionary<string, JobWithTrigger>();}public JobWithTrigger CreateJobWithTrigger<TJob>(string cronExpr, IDictionary<string, object> jobData = null) where TJob : IJob{var jobType = typeof(TJob);string jobTypeName = jobType.Name;if (jobType.IsGenericType){jobTypeName = jobType.GetGenericArguments()[0].Name;}IJobDetail job = null;if (jobData == null)job = JobBuilder.Create<TJob>().WithIdentity(jobTypeName).Build();elsejob = JobBuilder.Create<TJob>().WithIdentity(jobTypeName).UsingJobData(new JobDataMap(jobData)).Build();ITrigger trigger = TriggerBuilder.Create().WithIdentity(jobTypeName + "-Trigger").ForJob(job).StartNow().WithCronSchedule(cronExpr).Build();var jt = new JobWithTrigger(job, trigger);JobTriggers[jt.Key] = jt;return jt;}public void ScheduleJobs(params JobWithTrigger[] jts){if (scheduler.IsShutdown){scheduler = GetAScheduler();}foreach (var jt in jts){scheduler.ScheduleJob(jt.JobDetail, jt.Trigger);}}public void ScheduleJobs(params string[] jtKeys){var jts = JobTriggers.Where(t => jtKeys.Contains(t.Key)).Select(t => t.Value).ToArray();ScheduleJobs(jts);}public void UnscheduleJobs(params TriggerKey[] triggerKeys){scheduler.UnscheduleJobs(triggerKeys.ToList());}public void UnscheduleJobs(params string[] jtKeys){var triggerKeyObjs = JobTriggers.Where(t => jtKeys.Contains(t.Key)).Select(t => t.Value.Trigger.Key).ToArray();UnscheduleJobs(triggerKeyObjs);}public int State{get{return schedulerState;  //0:未开始,1:开始,2:暂停,3:恢复,-1:停止}}[MethodImpl(MethodImplOptions.Synchronized)]public void Start(){if (schedulerState > 0) return;scheduler.Start();schedulerState = 1;Master.WriteMsg("AutoTimingExecSystem程序已启动，所有任务按计划开始执行。", false, true);}[MethodImpl(MethodImplOptions.Synchronized)]public void Stop(){if (schedulerState <= 0) return;scheduler.Clear();scheduler.Shutdown();schedulerState = -1;Master.WriteMsg("AutoTimingExecSystem程序已停止，所有任务停止执行。", false, true);}[MethodImpl(MethodImplOptions.Synchronized)]public void Pause(){if (schedulerState != 1) return;scheduler.PauseAll();schedulerState = 2;Master.WriteMsg("所有任务被取消或暂停执行。", false, true);}[MethodImpl(MethodImplOptions.Synchronized)]public void Resume(){if (schedulerState != 2) return;scheduler.ResumeAll();schedulerState = 1;Master.WriteMsg("所有任务重新恢复执行。", false, true);}}

    [Serializable]public class JobWithTrigger{public JobWithTrigger(){this.Key = Guid.NewGuid().ToString("N");}public JobWithTrigger(IJobDetail job, ITrigger trigger): this(){this.JobDetail = job;this.Trigger = trigger;}public IJobDetail JobDetail{ get; set; }public ITrigger Trigger{ get; set; }public string JobName{get{return this.JobDetail.Key.Name;}}public string TriggerName{get{return this.Trigger.Key.Name;}}public string Key{get;private set;}}

var jobManager = new JobManager();
var jt=jobManager.CreateJobWithTrigger<JobWraper<TestJob>>("0/5 * * * * ?");//这里面可以将jt的保存或显示到任务界面上...jobManager.ScheduleJobs(JobWithTrigger的KEY数组 或 JobWithTrigger对象)jobManager.Start(); jobManager.Stop();