Add job with lock to sample

samples/Foundatio.HostingSample/Jobs/EveryMinuteJob.cs

@@ -17,8 +17,7 @@ public EveryMinuteJob(ILoggerFactory loggerFactory)
 
     public async Task<JobResult> RunAsync(CancellationToken cancellationToken = default)
     {
-        if (_logger.IsEnabled(LogLevel.Information))
-            _logger.LogInformation("EveryMinuteJob Run Thread={ManagedThreadId}", Thread.CurrentThread.ManagedThreadId);
+        _logger.LogInformation("EveryMinuteJob Run Thread={ManagedThreadId}", Thread.CurrentThread.ManagedThreadId);
 
         await Task.Delay(TimeSpan.FromSeconds(4));
 

samples/Foundatio.HostingSample/Jobs/Sample1Job.cs

@@ -19,8 +19,7 @@ public Sample1Job(ILoggerFactory loggerFactory)
     public Task<JobResult> RunAsync(CancellationToken cancellationToken = default)
     {
         Interlocked.Increment(ref _iterationCount);
-        if (_logger.IsEnabled(LogLevel.Information))
-            _logger.LogTrace("Sample1Job Run #{IterationCount} Thread={ManagedThreadId}", _iterationCount, Thread.CurrentThread.ManagedThreadId);
+        _logger.LogTrace("Sample1Job Run #{IterationCount} Thread={ManagedThreadId}", _iterationCount, Thread.CurrentThread.ManagedThreadId);
 
         return Task.FromResult(JobResult.Success);
     }

samples/Foundatio.HostingSample/Jobs/Sample2Job.cs

@@ -23,8 +23,7 @@ public Task<JobResult> RunAsync(CancellationToken cancellationToken = default)
     {
         _lastRun = DateTime.UtcNow;
         Interlocked.Increment(ref _iterationCount);
-        if (_logger.IsEnabled(LogLevel.Information))
-            _logger.LogTrace("Sample2Job Run #{IterationCount} Thread={ManagedThreadId}", _iterationCount, Thread.CurrentThread.ManagedThreadId);
+        _logger.LogTrace("Sample2Job Run #{IterationCount} Thread={ManagedThreadId}", _iterationCount, Thread.CurrentThread.ManagedThreadId);
 
         return Task.FromResult(JobResult.Success);
     }

samples/Foundatio.HostingSample/Jobs/SampleLockJob.cs

@@ -0,0 +1,32 @@
+using System;
+using System.Threading;
+using System.Threading.Tasks;
+using Foundatio.Caching;
+using Foundatio.Jobs;
+using Foundatio.Lock;
+using Microsoft.Extensions.Logging;
+
+namespace Foundatio.HostingSample;
+
+[Job(Description = "Sample lock job", Interval = "5s")]
+public class SampleLockJob : JobWithLockBase
+{
+    private readonly ILockProvider _lockProvider;
+
+    public SampleLockJob(ICacheClient cache)
+    {
+        _lockProvider = new ThrottlingLockProvider(cache, 1, TimeSpan.FromMinutes(1));;
+    }
+
+    protected override Task<ILock> GetLockAsync(CancellationToken cancellationToken = default)
+    {
+        return _lockProvider.AcquireAsync(nameof(SampleLockJob), TimeSpan.FromMinutes(15), new CancellationToken(true));
+    }
+
+    protected override Task<JobResult> RunInternalAsync(JobContext context)
+    {
+        _logger.LogTrace("SampleLockJob Run Thread={ManagedThreadId}", Thread.CurrentThread.ManagedThreadId);
+
+        return Task.FromResult(JobResult.Success);
+    }
+}

samples/Foundatio.HostingSample/Program.cs

@@ -1,4 +1,4 @@
-using System;
+using System;
 using System.Diagnostics;
 using System.Linq;
 using System.Threading;
@@ -67,10 +67,12 @@
     if (sample1)
         builder.Services.AddJob("Sample1", sp => new Sample1Job(sp.GetRequiredService<ILoggerFactory>()), o => o.ApplyDefaults<Sample1Job>().WaitForStartupActions().InitialDelay(TimeSpan.FromSeconds(4)));
 
+    builder.Services.AddJob<SampleLockJob>(o => o.WaitForStartupActions().Name(nameof(SampleLockJob)));
+
     if (sample2)
     {
         builder.Services.AddHealthChecks().AddCheck<Sample2Job>("Sample2Job");
-        builder.Services.AddJob<Sample2Job>(o => o.WaitForStartupActions());
+        builder.Services.AddJob<Sample2Job>(o => o.WaitForStartupActions().Name(nameof(Sample2Job)));
     }
 
     // if you don't specify priority, actions will automatically be assigned an incrementing priority starting at 0