如何在 Quartz.net 中使用多线程
本文关键字:多线程 net Quartz | 更新日期: 2023-09-27 18:36:11
我打算使用 quartz.net 来处理文件。
- 我每小时会收到 1 个或更多文件,每个文件将有 1000 行用于不同的国家/地区。
- 我想读取这些行,验证,处理并将其插入多个表中。
- 我想选择 1 个文件,对于该文件中的每个不同国家/地区,我喜欢创建一个线程。这样 1 个线程将处理 1 个国家/地区的所有数据。
- 在给定时间,线程不应超过 5 个。
现在我如何在 quartz.net 中定义它?下面是我拥有的代码,其中我逐个文件和每一行遍历每个文件,并且我没有做任何多线程
计划作业
var properties = new NameValueCollection();
properties["quartz.scheduler.instanceName"] = "MyScheduler";
properties["quartz.threadPool.threadCount"] = "5";
ISchedulerFactory sf = new StdSchedulerFactory(properties);
IScheduler s = sf.GetScheduler();
if (!s.IsStarted)
s.Start();
var jobKey = new JobKey("UniqueJobName", "BatchProcess");
if (s.GetJobDetail(jobKey) != null)
return "Error! Already running";
IJobDetail jobDetail = JobBuilder.Create<CountryProcessJob>()
.WithIdentity(jobKey)
.Build();
ITrigger trigger = TriggerBuilder.Create()
.WithIdentity("UniqueTriggerName", "BatchProcess")
.StartAt(DateTime.Now.AddSeconds(1))
.Build();
s.ScheduleJob(jobDetail, trigger);
工作
public class CountryProcessJob : IJob
{
public void Execute(IJobExecutionContext context)
{
While() // TillAllFilesAreProcessed
{
// Read A File
While() //for each row in file
{
// validate
// Process
// Insert
}
}
}
}
我是否应该有一个主作业来一次循环浏览一个文件,然后在作业中定义多个作业来处理每个国家/地区?这就是如何在石英中实现多线程吗?
安排主要作业
var properties = new NameValueCollection();
properties["quartz.scheduler.instanceName"] = "MyScheduler";
properties["quartz.threadPool.threadCount"] = "5";
ISchedulerFactory sf = new StdSchedulerFactory(properties);
IScheduler s = sf.GetScheduler();
if (!s.IsStarted)
s.Start();
var jobKey = new JobKey("UniqueJobName", "BatchProcess");
if (s.GetJobDetail(jobKey) != null)
return "Error! Already running";
IJobDetail jobDetail = JobBuilder.Create<FileProcessJob>()
.WithIdentity(jobKey)
.Build();
ITrigger trigger = TriggerBuilder.Create()
.WithIdentity("UniqueTriggerName", "BatchProcess")
.StartAt(DateTime.Now.AddSeconds(1))
.Build();
s.ScheduleJob(jobDetail, trigger);
主要工作
public class FileProcessJob : IJob
{
public void Execute(IJobExecutionContext context)
{
while() // TillAllFilesAreProcessed
{
// Read A File
foreach(var eachCountry in file) //for each row in file
{
// Create a Job
var jobKey = new JobKey("UniqueCountryJobName", "BatchProcess");
if (s.GetJobDetail(jobKey) != null)
return "Error! Already running";
IJobDetail jobDetail = JobBuilder.Create<CountryProcessJob>()
.WithIdentity(jobKey)
.Build();
ITrigger trigger = TriggerBuilder.Create()
.WithIdentity("UniqueCountryTriggerName", "BatchProcess")
.StartAt(DateTime.Now.AddSeconds(1))
.Build();
s.ScheduleJob(jobDetail, trigger);
}
}
}
}
为每个国家/地区创建多个工作
public class CountryProcessJob : IJob
{
public void Execute(IJobExecutionContext context)
{
// For each row for that country
// validate
// Process
// Insert
}
}
那么我应该创建多个作业来实现多个线程同时运行吗?请帮助我运行 5 个并发线程,在一个文件中处理每个不同的国家/地区。
Quartz.Net 作业在单独的线程中运行。 因此,如果您想配置线程的最大 nuber,请查看以下答案: https://stackoverflow.com/a/4108795/745011
您可以创建一个单独的静态类,并在 execute 方法中调用它。静态类在内存中具有固定的空间。
public class ReadCountry : IJob
{
public void Execute(IJobExecutionContext context)
{
CountryProcessJob.DoIt();
}
}
国家/地区流程工作类
public static class CountryProcessJob
{
public static void DoIt()
{
While() // TillAllFilesAreProcessed
{
// Read A File
While() //for each row in file
{
// validate
// Process
// Insert
}
}
}
}