DotNext.Threading by .NET Foundation and Contributors

<PackageReference Include="DotNext.Threading" Version="5.9.0" />

---

API Diff between 5.9.0 and 5.5.0

54 Additions 2 Removals

DotNext.Threading

• public static class AsyncBridge
  • public static Task<CancellationToken> WaitAnyAsync(this ReadOnlySpan<CancellationToken> tokens)
  • public static Task<CancellationToken> WaitAnyAsync(this ReadOnlySpan<CancellationToken> tokens, out Func interruption)
  • public static ValueTask<bool> WaitAsync(this WaitHandle handle, TimeSpan timeout)
  • public static ValueTask<bool> WaitAsync(this WaitHandle handle)
  • public static ValueTask<bool> WaitAsync(this WaitHandle handle, TimeSpan timeout, CancellationToken token = default)
  • public static ValueTask WaitAsync(this WaitHandle handle, CancellationToken token = default)
• public static class AsyncLockAcquisition
  • public static ValueTask<Holder> AcquireWriteLockAsync<T>(this T obj, bool upgrade, CancellationToken token = default)
  • public static ValueTask<Holder> AcquireWriteLockAsync<T>(this T obj, bool upgrade, TimeSpan timeout, CancellationToken token = default)
• public static class LinkedTokenSourceFactory
  • public static bool CausedBy(this OperationCanceledException e, LinkedCancellationTokenSource source, CancellationToken token)

DotNext.Threading.Leases

• public abstract class LeaseConsumer : Disposable, IAsyncDisposable
  • protected struct AcquisitionResult
  • public double ClockDriftBound { get; set; }
  • public Timeout& modreq(System.Runtime.InteropServices.InAttribute) Expiration { get; }
  • public CancellationToken Token { get; }
  • protected LeaseConsumer(TimeProvider provider = null)
  • public ValueTask AcquireAsync(TimeSpan pauseDuration, Random pauseRandomizer = null, CancellationToken token = default)
  • public ValueTask DisposeAsync()
  • public Task<TResult> ExecuteAsync<TResult>(Func<CancellationToken, Task<TResult>> worker, CancellationToken token = default)
  • public ValueTask<bool> ReleaseAsync(CancellationToken token = default)
  • protected abstract ValueTask<LeaseIdentity?> ReleaseCoreAsync(LeaseIdentity identity, CancellationToken token)
  • public ValueTask<bool> TryAcquireAsync(CancellationToken token = default)
  • protected abstract ValueTask<AcquisitionResult?> TryAcquireCoreAsync(CancellationToken token = default)
  • public ValueTask<bool> TryRenewAsync(CancellationToken token = default)
  • protected abstract ValueTask<AcquisitionResult?> TryRenewCoreAsync(LeaseIdentity identity, CancellationToken token)
• public struct LeaseIdentity : IEquatable<LeaseIdentity>
  • public const ulong InitialVersion = 0
  • public Guid Id { get; set; }
  • public ulong Version { get; set; }
  • public static bool op_Equality(ref LeaseIdentity x, ref LeaseIdentity y)
  • public static bool op_Inequality(ref LeaseIdentity x, ref LeaseIdentity y)
  • public static bool op_LeftShift(ref LeaseIdentity x, ref LeaseIdentity y)
  • public static bool op_RightShift(ref LeaseIdentity x, ref LeaseIdentity y)
  • public bool Equals(LeaseIdentity other)
  • public bool Precedes(ref LeaseIdentity other)
• public abstract class LeaseProvider<TMetadata> : Disposable
  • public struct AcquisitionResult<TMetadata>
  • public struct State<TMetadata>
  • protected CancellationToken LifetimeToken { get; }
  • public TimeSpan TimeToLive { get; }
  • protected LeaseProvider(TimeSpan ttl, TimeProvider provider = null)
  • public ValueTask<AcquisitionResult<TMetadata>> AcquireAsync<TArg>(TArg arg, Func<TArg, TMetadata, CancellationToken, ValueTask<TMetadata>> updater, CancellationToken token = default)
  • public ValueTask<AcquisitionResult<TMetadata>> AcquireAsync(CancellationToken token = default)
  • protected abstract ValueTask<State<TMetadata>> GetStateAsync(CancellationToken token)
  • public ValueTask<LeaseIdentity?> ReleaseAsync<TArg>(LeaseIdentity identity, TArg arg, Func<TArg, TMetadata, CancellationToken, ValueTask<TMetadata>> updater, CancellationToken token = default)
  • public ValueTask<LeaseIdentity?> ReleaseAsync(LeaseIdentity identity, CancellationToken token = default)
  • public ValueTask<AcquisitionResult<TMetadata>?> TryAcquireAsync<TArg>(TArg arg, Func<TArg, TMetadata, CancellationToken, ValueTask<TMetadata>> updater, CancellationToken token = default)
  • public ValueTask<AcquisitionResult<TMetadata>?> TryAcquireAsync(CancellationToken token = default)
  • public ValueTask<AcquisitionResult<TMetadata>?> TryAcquireOrRenewAsync<TArg>(LeaseIdentity identity, TArg arg, Func<TArg, TMetadata, CancellationToken, ValueTask<TMetadata>> updater, CancellationToken token = default)
  • public ValueTask<AcquisitionResult<TMetadata>?> TryAcquireOrRenewAsync(LeaseIdentity identity, CancellationToken token = default)
  • public ValueTask<AcquisitionResult<TMetadata>?> TryRenewAsync<TArg>(LeaseIdentity identity, bool reacquire, TArg arg, Func<TArg, TMetadata, CancellationToken, ValueTask<TMetadata>> updater, CancellationToken token = default)
  • public ValueTask<AcquisitionResult<TMetadata>?> TryRenewAsync(LeaseIdentity identity, bool reacquire, CancellationToken token = default)
  • protected abstract ValueTask<bool> TryUpdateStateAsync(State<TMetadata> state, CancellationToken token)
  • public ValueTask<LeaseIdentity> UnsafeReleaseAsync<TArg>(TArg arg, Func<TArg, TMetadata, CancellationToken, ValueTask<TMetadata>> updater, CancellationToken token = default)
  • public ValueTask<LeaseIdentity> UnsafeReleaseAsync(CancellationToken token = default)
  • public ValueTask<LeaseIdentity?> UnsafeTryReleaseAsync<TArg>(TArg arg, Func<TArg, TMetadata, CancellationToken, ValueTask<TMetadata>> updater, CancellationToken token = default)
  • public ValueTask<LeaseIdentity?> UnsafeTryReleaseAsync(CancellationToken token = default)