DotNext.Threading by .NET Foundation and Contributors

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

---

API Diff between 5.18.1 and 5.9.0

63 Additions 20 Removals

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, CancellationToken token = default)
  • public ValueTask<ReadOrWriteSession<TKey, TValue>> ChangeAsync(TKey key, CancellationToken token = default)
  • public ValueTask DisposeAsync()
  • public bool Invalidate(TKey key, TimeSpan timeout, CancellationToken token = default)
  • 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, out ReadSession session, TimeSpan timeout, CancellationToken token = default)
  • public ValueTask<ReadSession<TKey, TValue>?> TryRemoveAsync(TKey key, CancellationToken token = default)

DotNext.Threading

• public static class AsyncBridge
  • public static CancellationToken AsCancellationToken(this Task task)
  • public static CancellationToken AsCancellationToken(this Task task, out Func disposeTokenSource)
• 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 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 LinkedCancellationTokenSource LinkTo(this ref CancellationToken first, ReadOnlySpan<CancellationToken> tokens)

DotNext.Threading.Leases

• public abstract class LeaseConsumer : Disposable, IAsyncDisposable
  • public LeaseIdentity& modreq(System.Runtime.InteropServices.InAttribute) LeaseId { get; }

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 Consumer<T> GetConsumer<T>(this TaskCompletionPipe<Task<T>> pipe)
  • 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)