using System; using System.Threading; namespace Polly.Bulkhead { internal static class BulkheadEngine { internal static TResult Implementation<TResult>(Func<Context, CancellationToken, TResult> action, Context context, Action<Context> onBulkheadRejected, SemaphoreSlim maxParallelizationSemaphore, SemaphoreSlim maxQueuedActionsSemaphore, CancellationToken cancellationToken) { if (maxQueuedActionsSemaphore.Wait(TimeSpan.Zero, cancellationToken)) try { maxParallelizationSemaphore.Wait(cancellationToken); try { return action(context, cancellationToken); } finally { maxParallelizationSemaphore.Release(); } } finally { maxQueuedActionsSemaphore.Release(); } onBulkheadRejected(context); throw new BulkheadRejectedException(); } } }