DotNext.Threading by .NET Foundation and Contributors

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

---

API Diff between 3.3.0 and 2.3.0

92 Additions 13 Removals

DotNext.Runtime.CompilerServices

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

DotNext.Threading

• public static class AsyncBridge
  • 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 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 class AsyncCorrelationSource<TKey, TValue>
  • public AsyncCorrelationSource(long concurrencyLevel, IEqualityComparer<TKey> comparer = null)
  • public void ClearCache()
  • public bool Pulse(TKey eventId, TValue value)
  • public void PulseAll(TValue value)
  • public void PulseAll(Exception e)
  • public void PulseAll(CancellationToken token)
  • public ValueTask<TValue> WaitAsync(TKey eventId, TimeSpan timeout, CancellationToken token = default)
  • public ValueTask<TValue> WaitAsync(TKey eventId, CancellationToken token = default)
• public class AsyncCounter : QueuedSynchronizer, IAsyncEvent, ISynchronizer, IDisposable
  • public bool TryDecrement()
• public class AsyncExchanger<T> : Disposable, IAsyncDisposable
  • public bool IsTerminated { get; }
  • public AsyncExchanger()
  • public ValueTask DisposeAsync()
  • public ValueTask<T> ExchangeAsync(T value, TimeSpan timeout, CancellationToken token = default)
  • public ValueTask<T> ExchangeAsync(T value, CancellationToken token = default)
  • public void Terminate(Exception exception = null)
  • public bool TryExchange(ref T value)
• public class AsyncExclusiveLock : QueuedSynchronizer, IAsyncDisposable
  • public ValueTask DisposeAsync()
• public class AsyncLazy<T>
  • public AsyncLazy(ValueFunc<Task<T>> valueFactory, bool resettable = false)
• public struct AsyncLock : IDisposable, IEquatable<AsyncLock>, IAsyncDisposable
  • 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, IAsyncDisposable
  • public ValueTask DisposeAsync()
  • public bool Validate(ref LockStamp stamp)
• public class AsyncSharedLock : QueuedSynchronizer, IAsyncDisposable
  • public bool IsStrongLockHeld { get; }
  • public ValueTask DisposeAsync()
• public class AsyncTimer : Disposable, IAsyncDisposable
  • public AsyncTimer(ValueFunc<CancellationToken, Task<bool>> callback)
  • public ValueTask DisposeAsync()
• public class AsyncTrigger : QueuedSynchronizer, IAsyncEvent, ISynchronizer, IDisposable
  • public bool EnsureState<TState>(TState state, Predicate<TState> condition)
  • 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 class ConcurrentObjectPool<T> : Disposable
• public sealed class ExchangeTerminatedException : Exception
• public interface ISynchronizer
  • bool HasWaiters { get; }
  • bool HasAnticipants { 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 interface IAwaiter
  • public bool IsCompleted { get; }
  • protected Future(bool runContinuationsAsynchronously = true, bool continueOnCapturedContext = false)
  • public ValueTask AsTask()
  • protected void Complete(Exception e = null)
  • protected void GetResult()
  • public void OnCompleted(Action callback)
• public abstract class Future<TResult> : IFuture, INotifyCompletion, IValueTaskSource<TResult>
  • public interface IAwaiter<TResult>
  • public bool IsCompleted { get; }
  • protected Future(bool runContinuationsAsynchronously = true, bool continueOnCapturedContext = false)
  • public ValueTask<TResult> AsTask()
  • protected void Complete(Result<TResult> e)
  • protected TResult GetResult()
  • public void OnCompleted(Action callback)
• public abstract class ManualResetCompletionSource : IThreadPoolWorkItem
  • protected virtual void AfterConsumed()
  • public short Reset()
  • public abstract bool TrySetCanceled(CancellationToken token)
  • public abstract bool TrySetException(Exception e)
• public abstract class ManualResetCompletionSource<T> : ManualResetCompletionSource where T : struct, IEquatable<T>
  • public T CreateTask(TimeSpan timeout, CancellationToken token)
• public class ValueTaskCompletionSource : ManualResetCompletionSource<ValueTask>, IValueTaskSource
  • public ValueTaskCompletionSource(bool runContinuationsAsynchronously = true)
  • protected virtual void BeforeCompleted(Exception e)
  • protected virtual Exception OnCanceled(CancellationToken token)
  • protected virtual Exception OnTimeout()
  • public bool TrySetCanceled(short completionToken, CancellationToken token)
  • public bool TrySetException(short completionToken, Exception e)
  • public bool TrySetResult()
  • public bool TrySetResult(short completionToken)
• public class ValueTaskCompletionSource<T> : ManualResetCompletionSource<ValueTask<T>>, IValueTaskSource<T>
  • public ValueTaskCompletionSource(bool runContinuationsAsynchronously = true)
  • protected virtual void BeforeCompleted(Result<T> result)
  • protected virtual Result<T> OnCanceled(CancellationToken token)
  • protected virtual Result<T> OnTimeout()
  • public bool TrySetCanceled(short completionToken, CancellationToken token)
  • public bool TrySetException(short completionToken, Exception e)
  • public bool TrySetResult(T value)
  • public bool TrySetResult(short completionToken, T value)
• public static class ValueTaskSynchronization
  • 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)
  • 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)
  • 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)
  • public static ValueTask<ValueTask<R>> WhenAny<R>(ValueTask<R> task1, ValueTask<R> task2, ValueTask<R> task3, ValueTask<R> task4, ValueTask<R> task5)
  • public static ValueTask<ValueTask<TResult>> WhenAny<TResult>(ValueTask<TResult> task1, ValueTask<TResult> task2, ValueTask<TResult> task3, ValueTask<TResult> task4, ValueTask<TResult> task5)