DotNext.Threading by .NET Foundation and Contributors

API Diff between 5.9.0 and 4.13.0

78 Additions 14 Removals

DotNext.Collections.Concurrent

public struct IndexPool : ISupplier<int>, IFunctional<Func<int>>, IConsumer<int>, IFunctional<Action<int>>, IReadOnlyCollection<int>, IEnumerable<int>, IEnumerable, IResettable
- public struct Enumerator
- public static int Capacity { get; }
- public static int MaxValue { get; }
- public int Count { get; }
- public bool IsEmpty { get; set; }
- public IndexPool()
- public IndexPool(int maxValue)
- public bool Contains(int value)
- public Enumerator GetEnumerator()
- public void Reset()
- public void Return(int value)
- public void Return(ReadOnlySpan<int> indices)
- public int Take()
- public int Take(Span<int> indices)
- public bool TryPeek(out int result)
- public bool TryTake(out int result)

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 class AsyncLazy<T> : ISupplier<CancellationToken, Task<T>>, IFunctional<Func<CancellationToken, Task<T>>>, IResettable
- public Task<T> Task { get; }
- public AsyncLazy(Func<Task<T>> valueFactory, bool resettable = false)
- public ConfiguredTaskAwaitable<T> ConfigureAwait(bool continueOnCapturedContext)
- public TaskAwaiter<T> GetAwaiter()
public struct AsyncLock : IDisposable, IEquatable<AsyncLock>, IAsyncDisposable
- public ValueTask<Holder> TryAcquireAsync(CancellationToken token)
public static class AsyncLockAcquisition
- public static ValueTask<Holder> AcquireLockAsync<T>(this T obj, TimeSpan timeout, CancellationToken token = default)
- public static ValueTask<Holder> AcquireReadLockAsync<T>(this T obj, TimeSpan timeout, CancellationToken token = default)
- public static ValueTask<Holder> SuppressCancellation(this ValueTask<Holder> result)
- public static ValueTask<Holder> SuppressDisposedState(this ValueTask<Holder> result)
- public static ValueTask<Holder> SuppressDisposedStateOrCancellation(this ValueTask<Holder> result)
- public static ValueTask<Holder> AcquireWriteLockAsync<T>(this T obj, TimeSpan timeout, CancellationToken token = default)
- 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 class AsyncTrigger<TState> : QueuedSynchronizer
public static class LinkedTokenSourceFactory
- public static bool CausedBy(this OperationCanceledException e, LinkedCancellationTokenSource source, CancellationToken token)

DotNext.Threading.Channels

public sealed class PersistentChannelOptions : ChannelOptions
- public IncrementingEventCounter ReadRateCounter { get; set; }
- public IncrementingEventCounter WriteRateCounter { get; set; }

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)

DotNext.Threading.Tasks

public static class TaskCompletionPipe
- public static IAsyncEnumerable<T> GetConsumer<T>(this TaskCompletionPipe<Task<T>> pipe)
- public struct Consumer<T> : IAsyncEnumerable<T>
- public static Consumer<T> GetConsumer<T>(this TaskCompletionPipe<Task<T>> pipe)
public class TaskCompletionPipe<T> : IAsyncEnumerable<T>, IResettable where T : Task
- public void Add(T task, object userData)
- public bool TryRead(out T task, out object userData)