Quartz.Net和队列应用demo

using System;
using System.Collections.Generic;
using System.Threading;

namespace ConsoleApplication1
{
    public static class Class1
    {
        static Queue<string> MsgQueue = new Queue<string>();
        //创建一个没有其他用途的对象作为锁，微软官方推荐做法
        private static Object thisLock = new Object();

        static Class1()
        {
            ThreadPool.QueueUserWorkItem(q =>
            {
                while (true)
                {
                    lock (thisLock)
                    {
                        if (MsgQueue.Count > 0)
                        {
                            string msg = MsgQueue.Dequeue();
                            //把内容记录起来之类的操作...
                        }
                        else
                        {
                            //队列中没有东西，就让线程休息下
                            Thread.Sleep(3000);
                        }
                    }
                }
            });
        }

        public static void Insert(string msg)
        {
            lock (thisLock)
            {
                MsgQueue.Enqueue(msg);
            }
        }
    }
}

Quartz.Net和队列结合控制台demo

using Quartz;
using Quartz.Impl;

namespace ConsoleApplication1
{
    class Program
    {
        static void Main(string[] args)
        {
            for (int i = 1; i <= 10; i++)
            {
                TestJob.Insert($"str{i} ");
            }

            //计划者
            IScheduler sched = StdSchedulerFactory.GetDefaultScheduler();
            //作业
            IJobDetail job1 = new JobDetailImpl("Job1", "JobGroup1", typeof(TestJob));
            //触发器
            ITrigger trigger1 = TriggerBuilder.Create()
                .WithIdentity("Trigger1", "TriggerGroup1")
                .StartNow() //现在开始
                .WithSimpleSchedule(x => x
                    .WithIntervalInSeconds(5) //5秒一次
                    .RepeatForever()) //不断重复
                .Build();

            ////存值
            //job1.JobDataMap.Add("key1", "value1");

            sched.ScheduleJob(job1, trigger1);
            sched.Start();
　　　　　　　　  Console.Read();
        }
    }
}

using Quartz;
using System;
using System.Collections.Generic;
using System.Threading;

namespace ConsoleApplication1
{
    public class TestJob : IJob //想成为作业就要实现此接口
    {
        static Queue<string> MsgQueue = new Queue<string>();
        private static Object thisLock = new Object();

        public static void Insert(string msg)
        {
            lock (thisLock)
            {
                MsgQueue.Enqueue(msg);
            }
        }

        public void Execute(IJobExecutionContext context)
        {
            lock (thisLock)
            {
                if (MsgQueue.Count > 0)
                {
                    string msg = MsgQueue.Dequeue();
                    Console.WriteLine(msg + DateTime.Now.ToString());
                }
                else
                {
                    //队列中没有东西，就让线程休息下
                    Thread.Sleep(3000);
                }
            }

            ////取值
            //JobDataMap dataMap = context.JobDetail.JobDataMap;
            //string content = dataMap.GetString("key1");
            //Console.WriteLine("作业执行，jobSays:" + content);
        }
    }
}