DotNext.Threading by Roman Sakno

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

---

API Diff between 2.3.0 and 3.1.0

23 Additions 35 Removals

DotNext.Runtime.CompilerServices

• public sealed class CancellationTokenFuture : Future<Task>, IAwaiter, IFuture, INotifyCompletion
  • public IAwaiter GetAwaiter()
• public sealed class WaitHandleFuture : Future<Task<bool>>, IAwaiter<bool>, IFuture, INotifyCompletion
  • public IAwaiter<bool> GetAwaiter()

DotNext.Threading

• public static class AsyncBridge
  • public static ValueTask WaitAsync(this CancellationToken token, bool completeAsCanceled = false)
  • public static ValueTask<bool> WaitAsync(this WaitHandle handle, TimeSpan timeout)
  • public static ValueTask<bool> WaitAsync(this WaitHandle handle)
  • public static CancellationTokenFuture WaitAsync(this CancellationToken token, bool completeAsCanceled = false)
  • public static WaitHandleFuture WaitAsync(this WaitHandle handle, TimeSpan timeout)
  • public static WaitHandleFuture WaitAsync(this WaitHandle handle)
• public class AsyncExchanger<T> : Disposable, IAsyncDisposable
• public class AsyncExclusiveLock : QueuedSynchronizer
  • public ValueTask DisposeAsync()
• public class AsyncLazy<T>
  • public AsyncLazy(ValueFunc<Task<T>> valueFactory, bool resettable = false)
• public struct AsyncLock : IDisposable, IEquatable<AsyncLock>
  • public ValueTask DisposeAsync()
• public static class AsyncLockAcquisition
  • public static Task<Holder> SuppressCancellation(this Task<Holder> result)
  • public static Task<Holder> SuppressDisposedState(this Task<Holder> result)
  • public static Task<Holder> SuppressDisposedStateOrCancellation(this Task<Holder> result)
• public class AsyncReaderWriterLock : QueuedSynchronizer
  • public ValueTask DisposeAsync()
  • public bool Validate(ref LockStamp stamp)
• public class AsyncSharedLock : QueuedSynchronizer
  • public bool IsStrongLockHeld { get; }
  • public ValueTask DisposeAsync()
• public class AsyncTimer : Disposable
  • public AsyncTimer(ValueFunc<CancellationToken, Task<bool>> callback)
  • public ValueTask DisposeAsync()
• public class AsyncTrigger : QueuedSynchronizer, IAsyncEvent, ISynchronizer, IDisposable
  • public void Signal<TState>(TState state, bool fairness)
  • public void Signal<TState, TArgs>(TState state, Action<TState, TArgs> mutator, TArgs args, bool fairness)
  • public void Signal<TState>(TState state, Action<TState> mutator, bool fairness)
  • public Task<bool> SignalAndWaitAsync(TimeSpan timeout, CancellationToken token = default)
  • public Task SignalAndWaitAsync(CancellationToken token = default)
  • public Task<bool> SignalAndWaitAsync<TState>(TState state, Predicate<TState> condition, TimeSpan timeout, bool fairness, CancellationToken token = default)
  • public Task SignalAndWaitAsync<TState>(TState state, Predicate<TState> condition, bool fairness, CancellationToken token = default)
  • public Task<bool> SignalAndWaitAsync<TState, TArgs>(TState state, Action<TState, TArgs> mutator, TArgs args, Predicate<TState> condition, TimeSpan timeout, bool fairness, CancellationToken token = default)
  • public Task SignalAndWaitAsync<TState, TArgs>(TState state, Action<TState, TArgs> mutator, TArgs args, Predicate<TState> condition, bool fairness, CancellationToken token = default)
  • public Task<bool> SignalAndWaitAsync<TState>(TState state, Action<TState> mutator, Predicate<TState> condition, TimeSpan timeout, bool fairness, CancellationToken token = default)
  • public Task SignalAndWaitAsync<TState>(TState state, Action<TState> mutator, Predicate<TState> condition, bool fairness, CancellationToken token = default)
• public sealed class ExchangeTerminatedException : Exception
• public class ConcurrentObjectPool<T> : Disposable
  • public interface IRental<T> : IDisposable
  • public int Capacity { get; }
  • public int WaitCount { get; }
  • public ConcurrentObjectPool(int capacity, ValueFunc<T> factory)
  • public ConcurrentObjectPool(int capacity, Func<T> factory)
  • public ConcurrentObjectPool(IEnumerable<T> objects)
  • public IRental<T> Rent(CancellationToken token)
  • public IRental<T> Rent()
• public interface ISynchronizer
  • bool HasAnticipants { get; }
  • bool HasWaiters { get; }

DotNext.Threading.Channels

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

DotNext.Threading.Tasks

• public abstract class Future : IFuture, INotifyCompletion, IValueTaskSource
• public abstract class Future<TResult> : IFuture, INotifyCompletion, IValueTaskSource<TResult>
• public static class ValueTaskSynchronization
  • public static ValueTask<ValueTask<TResult>> WhenAny<TResult>(ValueTask<TResult> task1, ValueTask<TResult> task2)
  • public static ValueTask<ValueTask<R>> WhenAny<R>(ValueTask<R> task1, ValueTask<R> task2)
  • public static ValueTask<ValueTask<TResult>> WhenAny<TResult>(ValueTask<TResult> task1, ValueTask<TResult> task2, ValueTask<TResult> task3)
  • public static ValueTask<ValueTask<R>> WhenAny<R>(ValueTask<R> task1, ValueTask<R> task2, ValueTask<R> task3)
  • public static ValueTask<ValueTask<TResult>> WhenAny<TResult>(ValueTask<TResult> task1, ValueTask<TResult> task2, ValueTask<TResult> task3, ValueTask<TResult> task4)
  • public static ValueTask<ValueTask<R>> WhenAny<R>(ValueTask<R> task1, ValueTask<R> task2, ValueTask<R> task3, ValueTask<R> task4)
  • public static ValueTask<ValueTask<TResult>> WhenAny<TResult>(ValueTask<TResult> task1, ValueTask<TResult> task2, ValueTask<TResult> task3, ValueTask<TResult> task4, ValueTask<TResult> task5)
  • public static ValueTask<ValueTask<R>> WhenAny<R>(ValueTask<R> task1, ValueTask<R> task2, ValueTask<R> task3, ValueTask<R> task4, ValueTask<R> task5)