DotNext.Threading by .NET Foundation and Contributors

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

---

API Diff between 5.0.0 and 5.16.1

22 Additions 53 Removals

DotNext.Collections.Concurrent

• public struct IndexPool : ISupplier<int>, IFunctional<Func<int>>, IConsumer<int>, IFunctional<Action<int>>, IReadOnlyCollection<int>, IEnumerable<int>, IEnumerable, IResettable

DotNext.Runtime.Caching

• public class RandomAccessCache<TKey, TValue> : Disposable, IAsyncDisposable

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, CancellationToken token = default)
  • public static ValueTask WaitAsync(this WaitHandle handle, CancellationToken token = default)
  • public static ValueTask<bool> WaitAsync(this WaitHandle handle, TimeSpan timeout)
  • public static ValueTask<bool> WaitAsync(this WaitHandle handle)
• public class AsyncEventHub : IResettable
  • public struct EventGroup : IReadOnlyCollection<int>, IEnumerable<int>, IEnumerable, IEquatable<EventGroup>
  • public EventGroup CaptureState()
  • public void CancelSuspendedCallers(CancellationToken token)
  • public void CaptureState(Span<bool> states)
  • public EventGroup Pulse(ref EventGroup events)
  • public EventGroup PulseAll()
  • 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 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 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 class AsyncExclusiveLock : QueuedSynchronizer, IAsyncDisposable
  • public bool TryAcquire(TimeSpan timeout, CancellationToken token = default)
• 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> 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 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.Leases

• public abstract class LeaseConsumer : Disposable, IAsyncDisposable
• public struct LeaseIdentity : IEquatable<LeaseIdentity>
• public abstract class LeaseProvider<TMetadata> : Disposable

DotNext.Threading.Tasks

• public abstract class ManualResetCompletionSource
  • protected virtual void CleanUp()
  • public void OnCompleted(Action<object> continuation, object state, short token, ValueTaskSourceOnCompletedFlags flags)
  • protected virtual void Cleanup()
• public static class TaskCompletionPipe
  • 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 static Consumer<T> GetConsumer<T>(this TaskCompletionPipe<Task<T>> pipe)
• 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 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)