42 lines
1.4 KiB
C#
42 lines
1.4 KiB
C#
|
using Microsoft.Extensions.Logging;
|
|||
|
|
|
|||
|
|
namespace Umbraco.Cms.Core;
|
|||
|
|
|
|||
|
|
|
|||
|
|
public class FireAndForgetRunner : IFireAndForgetRunner
|
|||
|
|
{
|
|||
|
|
private readonly ILogger<FireAndForgetRunner> _logger;
|
|||
|
|
|
|||
|
|
public FireAndForgetRunner(ILogger<FireAndForgetRunner> logger) => _logger = logger;
|
|||
|
|
|
|||
|
|
public void RunFireAndForget(Func<Task> task) => ExecuteBackgroundTask(task);
|
|||
|
|
|
|||
|
|
private Task ExecuteBackgroundTask(Func<Task> fn)
|
|||
|
|
{
|
|||
|
|
// it is also possible to use UnsafeQueueUserWorkItem which does not flow the execution context,
|
|||
|
|
// however that seems more difficult to use for async operations.
|
|||
|
|
|
|||
|
|
// Do not flow AsyncLocal to the child thread
|
|||
|
|
using (ExecutionContext.SuppressFlow())
|
|||
|
|
{
|
|||
|
|
// NOTE: ConfigureAwait(false) is irrelevant here, it is not needed because this is not being
|
|||
|
|
// awaited. ConfigureAwait(false) is only relevant when awaiting to prevent the SynchronizationContext
|
|||
|
|
// (very different from the ExecutionContext!) from running the continuation on the calling thread.
|
|||
|
|
return Task.Run(LoggingWrapper(fn));
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
private Func<Task> LoggingWrapper(Func<Task> fn) =>
|
|||
|
|
async () =>
|
|||
|
|
{
|
|||
|
|
try
|
|||
|
|
{
|
|||
|
|
await fn();
|
|||
|
|
}
|
|||
|
|
catch (Exception e)
|
|||
|
|
{
|
|||
|
|
_logger.LogError(e, "Exception thrown in a background thread");
|
|||
|
|
}
|
|||
|
|
};
|
|||
|
|
}
|