glax/Tranga
2
0
Fork 0
Code

Merged MonitorJobs and CheckJobs in JobBoss

Browse Source
This commit is contained in:
glax 2023-08-24 13:34:09 +02:00
parent 8f309fcfd7
commit 58db049496
1 changed files with 3 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
Tranga/Jobs/JobBoss.cs
View File

@ -14,13 +14,6 @@ public class JobBoss : GlobalBase
this.mangaConnectorJobQueue = new(); this.mangaConnectorJobQueue = new();
} }
public void MonitorJobs()
{
foreach (Job job in jobs.Where(job => job.nextExecution < DateTime.Now && !QueueContainsJob(job)).OrderBy(job => job.nextExecution))
AddJobToQueue(job);
CheckJobQueue();
}
public void AddJob(Job job) public void AddJob(Job job)
{ {
this.jobs.Add(job); this.jobs.Add(job);
@ -53,8 +46,10 @@ public class JobBoss : GlobalBase
AddJobToQueue(job); AddJobToQueue(job);
} }
private void CheckJobQueue() public void CheckJobs()
{ {
foreach (Job job in jobs.Where(job => job.nextExecution < DateTime.Now && !QueueContainsJob(job)).OrderBy(job => job.nextExecution))
AddJobToQueue(job);
foreach (Queue<Job> jobQueue in mangaConnectorJobQueue.Values) foreach (Queue<Job> jobQueue in mangaConnectorJobQueue.Values)
{ {
Job queueHead = jobQueue.Peek(); Job queueHead = jobQueue.Peek();