From 9f387d5ab24781cec0a7d0baef06ee49069b3c95 Mon Sep 17 00:00:00 2001 From: liangshiwei Date: Sun, 15 Aug 2021 10:14:19 +0800 Subject: [PATCH 1/2] Use DisallowConcurrentExecution to keep a Job from firing concurrently --- .../Volo/Abp/BackgroundJobs/Quartz/QuartzJobExecutionAdapter.cs | 1 + .../BackgroundWorkers/Quartz/QuartzBackgroundWorkerAdapter.cs | 1 + 2 files changed, 2 insertions(+) diff --git a/framework/src/Volo.Abp.BackgroundJobs.Quartz/Volo/Abp/BackgroundJobs/Quartz/QuartzJobExecutionAdapter.cs b/framework/src/Volo.Abp.BackgroundJobs.Quartz/Volo/Abp/BackgroundJobs/Quartz/QuartzJobExecutionAdapter.cs index 79776d0726..96c787c511 100644 --- a/framework/src/Volo.Abp.BackgroundJobs.Quartz/Volo/Abp/BackgroundJobs/Quartz/QuartzJobExecutionAdapter.cs +++ b/framework/src/Volo.Abp.BackgroundJobs.Quartz/Volo/Abp/BackgroundJobs/Quartz/QuartzJobExecutionAdapter.cs @@ -9,6 +9,7 @@ using Volo.Abp.Json; namespace Volo.Abp.BackgroundJobs.Quartz { + [DisallowConcurrentExecution] public class QuartzJobExecutionAdapter : IJob { public ILogger> Logger { get; set; } diff --git a/framework/src/Volo.Abp.BackgroundWorkers.Quartz/Volo/Abp/BackgroundWorkers/Quartz/QuartzBackgroundWorkerAdapter.cs b/framework/src/Volo.Abp.BackgroundWorkers.Quartz/Volo/Abp/BackgroundWorkers/Quartz/QuartzBackgroundWorkerAdapter.cs index a37807e473..aa99434ed5 100644 --- a/framework/src/Volo.Abp.BackgroundWorkers.Quartz/Volo/Abp/BackgroundWorkers/Quartz/QuartzBackgroundWorkerAdapter.cs +++ b/framework/src/Volo.Abp.BackgroundWorkers.Quartz/Volo/Abp/BackgroundWorkers/Quartz/QuartzBackgroundWorkerAdapter.cs @@ -6,6 +6,7 @@ using Volo.Abp.Threading; namespace Volo.Abp.BackgroundWorkers.Quartz { + [DisallowConcurrentExecution] public class QuartzPeriodicBackgroundWorkerAdapter : QuartzBackgroundWorkerBase, IQuartzBackgroundWorkerAdapter where TWorker : IBackgroundWorker From 5737d1909f108c8efd67a84acd9aa638b4174e66 Mon Sep 17 00:00:00 2001 From: liangshiwei Date: Mon, 16 Aug 2021 11:01:39 +0800 Subject: [PATCH 2/2] Update QuartzJobExecutionAdapter.cs --- .../Volo/Abp/BackgroundJobs/Quartz/QuartzJobExecutionAdapter.cs | 1 - ...WorkerAdapter.cs => QuartzPeriodicBackgroundWorkerAdapter.cs} | 0 2 files changed, 1 deletion(-) rename framework/src/Volo.Abp.BackgroundWorkers.Quartz/Volo/Abp/BackgroundWorkers/Quartz/{QuartzBackgroundWorkerAdapter.cs => QuartzPeriodicBackgroundWorkerAdapter.cs} (100%) diff --git a/framework/src/Volo.Abp.BackgroundJobs.Quartz/Volo/Abp/BackgroundJobs/Quartz/QuartzJobExecutionAdapter.cs b/framework/src/Volo.Abp.BackgroundJobs.Quartz/Volo/Abp/BackgroundJobs/Quartz/QuartzJobExecutionAdapter.cs index 96c787c511..79776d0726 100644 --- a/framework/src/Volo.Abp.BackgroundJobs.Quartz/Volo/Abp/BackgroundJobs/Quartz/QuartzJobExecutionAdapter.cs +++ b/framework/src/Volo.Abp.BackgroundJobs.Quartz/Volo/Abp/BackgroundJobs/Quartz/QuartzJobExecutionAdapter.cs @@ -9,7 +9,6 @@ using Volo.Abp.Json; namespace Volo.Abp.BackgroundJobs.Quartz { - [DisallowConcurrentExecution] public class QuartzJobExecutionAdapter : IJob { public ILogger> Logger { get; set; } diff --git a/framework/src/Volo.Abp.BackgroundWorkers.Quartz/Volo/Abp/BackgroundWorkers/Quartz/QuartzBackgroundWorkerAdapter.cs b/framework/src/Volo.Abp.BackgroundWorkers.Quartz/Volo/Abp/BackgroundWorkers/Quartz/QuartzPeriodicBackgroundWorkerAdapter.cs similarity index 100% rename from framework/src/Volo.Abp.BackgroundWorkers.Quartz/Volo/Abp/BackgroundWorkers/Quartz/QuartzBackgroundWorkerAdapter.cs rename to framework/src/Volo.Abp.BackgroundWorkers.Quartz/Volo/Abp/BackgroundWorkers/Quartz/QuartzPeriodicBackgroundWorkerAdapter.cs