DotNext.Threading by .NET Foundation and Contributors

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

---

API Diff between 5.17.2 and 4.15.2

140 Additions 33 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 : IEnumerator<Enumerator, int>
  • 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.Runtime.Caching

• public class RandomAccessCache<TKey, TValue> : Disposable, IAsyncDisposable
  • public struct ReadOrWriteSession<TKey, TValue> : IDisposable
  • public struct ReadSession<TKey, TValue> : IDisposable
  • public Action<TKey, TValue> Eviction { get; set; }
  • public IEqualityComparer<TKey> KeyComparer { get; set; }
  • public RandomAccessCache(int cacheSize)
  • public ReadOrWriteSession<TKey, TValue> Change(TKey key, TimeSpan timeout)
  • public ValueTask<ReadOrWriteSession<TKey, TValue>> ChangeAsync(TKey key, CancellationToken token = default)
  • public ValueTask DisposeAsync()
  • public bool Invalidate(TKey key, TimeSpan timeout)
  • public ValueTask<bool> InvalidateAsync(TKey key, CancellationToken token = default)
  • public ValueTask InvalidateAsync(CancellationToken token = default)
  • public bool TryRead(TKey key, out ReadSession session)
  • public bool TryRemove(TKey key, TimeSpan timeout, out ReadSession session)
  • public ValueTask<ReadSession<TKey, TValue>?> TryRemoveAsync(TKey key, CancellationToken token = default)

DotNext.Threading

• public class AsyncAutoResetEvent : QueuedSynchronizer, IAsyncResetEvent, IAsyncEvent, IDisposable, IResettable
  • public bool Wait(TimeSpan timeout)
• public static class AsyncBridge
  • public static CancellationToken AsCancellationToken(this Task task)
  • public static CancellationToken AsCancellationToken(this Task task, out Func disposeTokenSource)
  • 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 AsyncEventHub : QueuedSynchronizer, IResettable
  • public struct EventGroup : IReadOnlyCollection<int>, IEnumerable<int>, IEnumerable, IEquatable<EventGroup>
  • public void CancelSuspendedCallers(CancellationToken token)
  • public void CaptureState(Span<bool> states)
  • public EventGroup CaptureState()
  • public int Pulse(ReadOnlySpan<int> eventIndexes)
  • public void Pulse(ReadOnlySpan<int> eventIndexes, Span<bool> flags)
  • public int PulseAll()
  • public void PulseAll(Span<bool> flags)
  • public EventGroup Pulse(ref EventGroup events)
  • public EventGroup PulseAll()
  • public int ResetAndPulse(ReadOnlySpan<int> eventIndexes)
  • public void ResetAndPulse(ReadOnlySpan<int> eventIndexes, Span<bool> flags)
  • public Task WaitAllAsync(ReadOnlySpan<int> eventIndexes, TimeSpan timeout, CancellationToken token = default)
  • public Task WaitAllAsync(ReadOnlySpan<int> eventIndexes, CancellationToken token = default)
  • public Task WaitAllAsync(TimeSpan timeout, CancellationToken token = default)
  • public Task WaitAllAsync(CancellationToken token = default)
  • public Task<int> WaitAnyAsync(ReadOnlySpan<int> eventIndexes, TimeSpan timeout, CancellationToken token = default)
  • public Task<int> WaitAnyAsync(ReadOnlySpan<int> eventIndexes, CancellationToken token = default)
  • public Task<int> WaitAnyAsync(TimeSpan timeout, CancellationToken token = default)
  • public Task<int> WaitAnyAsync(CancellationToken token = default)
  • public Task WaitOneAsync(int eventIndex, TimeSpan timeout, CancellationToken token = default)
  • public Task WaitOneAsync(int eventIndex, CancellationToken token = default)
  • public EventGroup ResetAndPulse(ref EventGroup events)
  • public ValueTask WaitAllAsync(ref EventGroup events, TimeSpan timeout, CancellationToken token = default)
  • public ValueTask WaitAllAsync(ref EventGroup events, CancellationToken token = default)
  • public ValueTask WaitAllAsync(TimeSpan timeout, CancellationToken token = default)
  • public ValueTask WaitAllAsync(CancellationToken token = default)
  • public ValueTask WaitAnyAsync(ref EventGroup events, TimeSpan timeout, CancellationToken token = default)
  • public ValueTask WaitAnyAsync(ref EventGroup events, CancellationToken token = default)
  • public ValueTask WaitAnyAsync(ref EventGroup events, ICollection<int> output, TimeSpan timeout, CancellationToken token = default)
  • public ValueTask WaitAnyAsync(ref EventGroup events, ICollection<int> output, CancellationToken token = default)
  • public ValueTask WaitAnyAsync(TimeSpan timeout, CancellationToken token = default)
  • public ValueTask WaitAnyAsync(CancellationToken token = default)
  • public ValueTask WaitAnyAsync(ICollection<int> output, TimeSpan timeout, CancellationToken token = default)
  • public ValueTask WaitAnyAsync(ICollection<int> output, CancellationToken token = default)
  • public ValueTask WaitOneAsync(int eventIndex, TimeSpan timeout, CancellationToken token = default)
  • public ValueTask WaitOneAsync(int eventIndex, CancellationToken token = default)
• public class AsyncExclusiveLock : QueuedSynchronizer, IAsyncDisposable
  • public bool TryAcquire(TimeSpan timeout, 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 AsyncManualResetEvent : QueuedSynchronizer, IAsyncResetEvent, IAsyncEvent, IDisposable, IResettable
  • public bool Wait(TimeSpan timeout)
• public class AsyncReaderWriterLock : QueuedSynchronizer, IAsyncDisposable
  • public bool TryEnterReadLock(TimeSpan timeout, CancellationToken token = default)
  • public bool TryEnterWriteLock(TimeSpan timeout, CancellationToken token = default)
• public class AsyncTrigger<TState> : QueuedSynchronizer
• public interface IAsyncEvent : IDisposable, IResettable
  • bool Wait(TimeSpan timeout)
• public static class LinkedTokenSourceFactory
  • public static bool CausedBy(this OperationCanceledException e, LinkedCancellationTokenSource source, CancellationToken token)
  • public static LinkedCancellationTokenSource LinkTo(this ref CancellationToken first, ReadOnlySpan<CancellationToken> tokens)

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 LeaseIdentity& modreq(System.Runtime.InteropServices.InAttribute) LeaseId { 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 abstract class ManualResetCompletionSource
  • protected virtual void Cleanup()
  • protected virtual void CleanUp()
  • public void OnCompleted(Action<object> continuation, object state, short token, ValueTaskSourceOnCompletedFlags flags)
• 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> Consume<T>(this TaskCompletionPipe<Task<T>> pipe)
  • public static Consumer<T> Consume<T>(this ReadOnlySpan<Task<T>> tasks)
  • public static IAsyncEnumerable<T> WhenEach<T>(ReadOnlySpan<T> tasks) where T : Task
• public class TaskCompletionPipe<T> : IAsyncEnumerable<T>, IResettable where T : Task
  • public Task Completion { get; }
  • public bool IsCompletionTaskSupported { get; set; }
  • public void Add(ReadOnlySpan<T> tasks, bool complete = false, object userData = null)
• public class TaskQueue<T> : IAsyncEnumerable<T>, IResettable where T : Task
  • public bool CanEnqueue { get; }
  • public T HeadTask { get; }
  • public TaskQueue(int capacity)
  • public void Clear()
  • public ValueTask<T> DequeueAsync(CancellationToken token = default)
  • public ValueTask EnqueueAsync(T task, CancellationToken token = default)
  • public ValueTask EnsureFreeSpaceAsync(CancellationToken token = default)
  • public IAsyncEnumerator<T> GetAsyncEnumerator(CancellationToken token)
  • public bool TryDequeue(out T task)
  • public ValueTask<T> TryDequeueAsync(CancellationToken token = default)
  • public bool TryEnqueue(T task)
• public class ValueTaskCompletionSource<T> : ManualResetCompletionSource, IValueTaskSource<T>, IValueTaskSource, ISupplier<TimeSpan, CancellationToken, ValueTask>, IFunctional<Func<TimeSpan, CancellationToken, ValueTask>>, ISupplier<TimeSpan, CancellationToken, ValueTask<T>>, IFunctional<Func<TimeSpan, CancellationToken, ValueTask<T>>>
  • public ValueTaskSourceStatus GetStatus(short token)