Estoy tratando de usar Hangfire para ejecutar un trabajo recurrente en segundo plano que sondea datos de otro sitio web, el problema es que no quiero que se ejecute el trabajo recurrente si el trabajo anterior aún se está ejecutando.
He leído la documentación pero parece que no puedo encontrar la respuesta. ¿Hay alguna manera de tener un trabajo recurrente que se ejecute cada 10 minutos pero se salte si la tarea anterior aún no se ha realizado?
public void Configuration(IAppBuilder app) { app.MapSignalR(); // Hangfire GlobalConfiguration.Configuration .UseSqlServerStorage("DatabaseContext"); app.UseHangfireDashboard(); app.UseHangfireServer(); RecurringJob.AddOrUpdate("site-parser", () => SiteParserService.RunAll(), Cron.Minutely, TimeZoneInfo.Utc); ConfigureAuth(app); }Puedes usar; [DisableConcurrentExecution(10 * 60)] atributo en el método de trabajo.
Aquí puede encontrar información sobre este atributo: http://odinserj.net/2014/05/21/hangfire-0.8.2-released/
Mi solución:
namespace MyNameSpace { public delegate void LockWrapperDelegateVoid(); /* Job Locker. One job can work at current moment. Different jobs can work parallel */ public static class JobLocker { private static readonly ConcurrentDictionary<string, bool> _locks = new ConcurrentDictionary<string, bool>(); private static string LocksTryAdd(string lockerName) { if (string.IsNullOrEmpty(lockerName)) // lock by procedure's name (in this example = "JobProcedure") { lockerName = new StackFrame(2).GetMethod().Name; } if (!_locks.ContainsKey(lockerName)) { _locks.TryAdd(lockerName, false); } return lockerName; } public static void LockWrapperVoid(string lockerName, LockWrapperDelegateVoid lockWrapperDelegateVoid) { lockerName = LocksTryAdd(lockerName); if (!_locks[lockerName]) { _locks[lockerName] = true; try { lockWrapperDelegateVoid(); } finally { _locks[lockerName] = false; } } } } } // USING // JOB description TryAddOrUpdateJob("JOB TITLE", () => JobManager.JobProcedure(), "* * * * *", TimeZoneInfo.Utc, "queueDefault"); // every one minute public static void JobProcedure() { // very important. You can use "BlockArea" instead null and use one area if several jobs depend each other // if null - area will have name like as the procedure ("JobProcedure") JobLocker.LockWrapperVoid(null, () => { //your code here System.Threading.Thread.Sleep(2 * 1000 * 60); // timeout - 2 minutes }); }