DotNext.Threading by Roman Sakno

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

---

API Diff between 2.4.0 and 4.0.0-beta.1

100 Additions 88 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 class AsyncAutoResetEvent : QueuedSynchronizer, IAsyncResetEvent, IAsyncEvent, ISynchronizer, IDisposable
  • public AsyncAutoResetEvent(bool initialState, int concurrencyLevel)
  • public ValueTask<bool> WaitAsync(TimeSpan timeout, CancellationToken token = default)
  • public ValueTask WaitAsync(CancellationToken token = default)
  • public Task<bool> WaitAsync(TimeSpan timeout, CancellationToken token)
• public class AsyncBarrier : Disposable, IAsyncEvent, ISynchronizer, IDisposable
  • protected virtual ValueTask PostPhase(long phase)
  • protected virtual Task PostPhase(long phase)
  • public ValueTask<bool> SignalAndWaitAsync(TimeSpan timeout, CancellationToken token = default)
  • public ValueTask SignalAndWaitAsync(CancellationToken token = default)
  • public ValueTask<bool> WaitAsync(TimeSpan timeout, CancellationToken token = default)
  • public ValueTask WaitAsync(CancellationToken token = default)
  • public Task<bool> SignalAndWaitAsync(TimeSpan timeout, CancellationToken token = default)
  • public Task SignalAndWaitAsync(CancellationToken token)
  • public Task SignalAndWaitAsync()
  • public Task<bool> WaitAsync(TimeSpan timeout, CancellationToken token)
• public static class AsyncBridge
  • public static int MaxPoolSize { get; set; }
  • 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 AsyncCorrelationSource<TKey, TValue>
• public class AsyncCountdownEvent : Synchronizer, IAsyncEvent, ISynchronizer, IDisposable
  • public bool IsSet { get; }
  • public AsyncCountdownEvent(long initialCount, int concurrencyLevel)
  • public bool Signal()
  • public ValueTask<bool> WaitAsync(TimeSpan timeout, CancellationToken token = default)
  • public ValueTask WaitAsync(CancellationToken token = default)
• public class AsyncCounter : QueuedSynchronizer, IAsyncEvent, ISynchronizer, IDisposable
  • public AsyncCounter(long initialValue, int concurrencyLevel)
  • public bool TryDecrement()
  • public ValueTask<bool> WaitAsync(TimeSpan timeout, CancellationToken token = default)
  • public ValueTask WaitAsync(CancellationToken token = default)
  • public Task<bool> WaitAsync(TimeSpan timeout, CancellationToken token)
• public class AsyncExchanger<T> : Disposable, IAsyncDisposable
• public static class AsyncEvent
  • public static Task<bool> WaitAsync(this IAsyncEvent event, TimeSpan timeout)
  • public static Task WaitAsync(this IAsyncEvent event, CancellationToken token)
  • public static Task WaitAsync(this IAsyncEvent event)
• public class AsyncExclusiveLock : QueuedSynchronizer
  • public AsyncExclusiveLock(int concurrencyLevel)
  • public ValueTask AcquireAsync(TimeSpan timeout, CancellationToken token = default)
  • public ValueTask AcquireAsync(CancellationToken token = default)
  • public Task AcquireAsync(TimeSpan timeout, CancellationToken token = default)
  • public Task AcquireAsync(CancellationToken token)
  • public ValueTask<bool> TryAcquireAsync(TimeSpan timeout, CancellationToken token = default)
  • public Task<bool> TryAcquireAsync(TimeSpan timeout, CancellationToken token)
  • public Task<bool> TryAcquireAsync(TimeSpan timeout)
• public class AsyncLazy<T>
  • public AsyncLazy(ValueFunc<Task<T>> valueFactory, bool resettable = false)
• public struct AsyncLock : IDisposable, IEquatable<AsyncLock>
  • public static AsyncLock ReadLock(AsyncReaderWriterLock rwLock)
  • public static AsyncLock ReadLock(AsyncReaderWriterLock rwLock, bool upgradeable)
  • public static AsyncLock WriteLock(AsyncReaderWriterLock rwLock, bool upgrade = false)
  • public ValueTask<Holder> AcquireAsync(CancellationToken token)
  • public ValueTask<Holder> AcquireAsync(TimeSpan timeout, CancellationToken token = default)
  • public static AsyncLock WriteLock(AsyncReaderWriterLock rwLock)
  • public Task<Holder> AcquireAsync(CancellationToken token)
  • public Task<Holder> AcquireAsync(TimeSpan timeout, CancellationToken token = default)
  • public ValueTask DisposeAsync()
  • public ValueTask<Holder> TryAcquireAsync(TimeSpan timeout, CancellationToken token = default)
  • public ValueTask<Holder> TryAcquireAsync(CancellationToken token)
  • public Task<Holder> TryAcquireAsync(TimeSpan timeout, bool suppressCancellation, CancellationToken token)
  • public Task<Holder> TryAcquireAsync(TimeSpan timeout, CancellationToken token = default)
  • public Task<Holder> TryAcquireAsync(CancellationToken token)
• public static class AsyncLockAcquisition
  • public static ValueTask<Holder> AcquireLockAsync<T>(this T obj, TimeSpan timeout)
  • public static ValueTask<Holder> AcquireLockAsync<T>(this T obj, CancellationToken token)
  • public static ValueTask<Holder> AcquireReadLockAsync<T>(this T obj, TimeSpan timeout)
  • public static ValueTask<Holder> AcquireReadLockAsync<T>(this T obj, CancellationToken token)
  • public static ValueTask<Holder> AcquireWriteLockAsync<T>(this T obj, TimeSpan timeout)
  • public static ValueTask<Holder> AcquireWriteLockAsync<T>(this T obj, CancellationToken token)
  • 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 Task<Holder> AcquireLockAsync<T>(this T obj, TimeSpan timeout)
  • public static Task<Holder> AcquireLockAsync<T>(this T obj, CancellationToken token)
  • public static Task<Holder> AcquireReadLockAsync<T>(this T obj, TimeSpan timeout)
  • public static Task<Holder> AcquireReadLockAsync<T>(this T obj, CancellationToken token)
  • public static Task<Holder> AcquireUpgradeableReadLockAsync<T>(this T obj, TimeSpan timeout)
  • public static Task<Holder> AcquireUpgradeableReadLockAsync<T>(this T obj, CancellationToken token)
  • public static Task<Holder> AcquireWriteLockAsync<T>(this T obj, TimeSpan timeout)
  • public static Task<Holder> AcquireWriteLockAsync<T>(this T obj, CancellationToken token)
• public class AsyncManualResetEvent : Synchronizer, IAsyncResetEvent, IAsyncEvent, ISynchronizer, IDisposable
  • public bool IsSet { get; }
  • public AsyncManualResetEvent(bool initialState, int concurrencyLevel)
  • public ValueTask<bool> WaitAsync(TimeSpan timeout, CancellationToken token = default)
  • public ValueTask WaitAsync(CancellationToken token = default)
  • public ValueTask<bool> WaitAsync<T>(Predicate<T> condition, T arg, TimeSpan timeout, CancellationToken token = default)
  • public ValueTask WaitAsync<T>(Predicate<T> condition, T arg, CancellationToken token = default)
  • public ValueTask<bool> WaitAsync<T1, T2>(Func<T1, T2, bool> condition, T1 arg1, T2 arg2, TimeSpan timeout, CancellationToken token = default)
  • public ValueTask WaitAsync<T1, T2>(Func<T1, T2, bool> condition, T1 arg1, T2 arg2, CancellationToken token = default)
• public class AsyncReaderWriterLock : QueuedSynchronizer
  • public bool IsUpgradeableReadLockHeld { get; }
  • public AsyncReaderWriterLock(int concurrencyLevel)
  • public void DowngradeFromWriteLock()
  • public ValueTask EnterReadLockAsync(TimeSpan timeout, CancellationToken token = default)
  • public ValueTask EnterReadLockAsync(CancellationToken token = default)
  • public ValueTask EnterWriteLockAsync(CancellationToken token = default)
  • public ValueTask EnterWriteLockAsync(TimeSpan timeout, CancellationToken token = default)
  • public void Release()
  • public Task EnterReadLockAsync(CancellationToken token)
  • public Task EnterReadLockAsync(TimeSpan timeout, CancellationToken token = default)
  • public Task EnterUpgradeableReadLockAsync(CancellationToken token)
  • public Task EnterUpgradeableReadLockAsync(TimeSpan timeout, CancellationToken token = default)
  • public Task EnterWriteLockAsync(CancellationToken token)
  • public Task EnterWriteLockAsync(TimeSpan timeout, CancellationToken token = default)
  • public void ExitReadLock()
  • public void ExitUpgradeableReadLock()
  • public void ExitWriteLock()
  • public ValueTask<bool> TryEnterReadLockAsync(TimeSpan timeout, CancellationToken token = default)
  • public Task<bool> TryEnterReadLockAsync(TimeSpan timeout, CancellationToken token)
  • public Task<bool> TryEnterReadLockAsync(TimeSpan timeout)
  • public bool TryEnterUpgradeableReadLock()
  • public Task<bool> TryEnterUpgradeableReadLockAsync(TimeSpan timeout, CancellationToken token)
  • public Task<bool> TryEnterUpgradeableReadLockAsync(TimeSpan timeout)
  • public ValueTask<bool> TryEnterWriteLockAsync(TimeSpan timeout, CancellationToken token = default)
  • public Task<bool> TryEnterWriteLockAsync(TimeSpan timeout, CancellationToken token)
  • public Task<bool> TryEnterWriteLockAsync(TimeSpan timeout)
  • public bool TryUpgradeToWriteLock()
  • public ValueTask<bool> TryUpgradeToWriteLockAsync(TimeSpan timeout, CancellationToken token = default)
  • public ValueTask UpgradeToWriteLockAsync(CancellationToken token = default)
  • public ValueTask UpgradeToWriteLockAsync(TimeSpan timeout, CancellationToken token = default)
  • public bool Validate(ref LockStamp stamp)
• public class AsyncSharedLock : QueuedSynchronizer
  • public bool IsStrongLockHeld { get; }
  • public AsyncSharedLock(long concurrencyLevel, bool limitedConcurrency = true)
  • public ValueTask AcquireAsync(bool strongLock, TimeSpan timeout, CancellationToken token = default)
  • public ValueTask AcquireAsync(bool strongLock, CancellationToken token = default)
  • public AsyncSharedLock(long concurrencyLevel)
  • public Task AcquireAsync(bool strongLock, TimeSpan timeout, CancellationToken token = default)
  • public Task AcquireAsync(bool strongLock, CancellationToken token)
  • public ValueTask<bool> TryAcquireAsync(bool strongLock, TimeSpan timeout, CancellationToken token = default)
  • public Task<bool> TryAcquireAsync(bool strongLock, TimeSpan timeout, CancellationToken token)
  • public Task<bool> TryAcquireAsync(bool strongLock, TimeSpan timeout)
• public class AsyncTimer : Disposable
  • public bool IsRunning { get; }
  • public AsyncTimer(ValueFunc<CancellationToken, Task<bool>> callback)
  • public AsyncTimer(Func<CancellationToken, Task<bool>> callback)
  • public bool Start(TimeSpan dueTime, TimeSpan period, CancellationToken token = default)
  • public bool Start(TimeSpan period, CancellationToken token = default)
  • public Task<bool> StopAsync()
• public class AsyncTrigger : QueuedSynchronizer, IAsyncEvent, ISynchronizer, IDisposable
  • public AsyncTrigger(int concurrencyLevel)
  • public bool Signal(bool resumeAll = false)
  • public ValueTask<bool> SignalAndWaitAsync(bool resumeAll, bool throwOnEmptyQueue, TimeSpan timeout, CancellationToken token = default)
  • public ValueTask SignalAndWaitAsync(bool resumeAll, bool throwOnEmptyQueue, CancellationToken token = default)
  • public ValueTask<bool> WaitAsync(TimeSpan timeout, CancellationToken token = default)
  • public ValueTask WaitAsync(CancellationToken token = default)
  • public Task WaitAsync<TStateMachine>(TStateMachine stateMachine, Predicate<TStateMachine> condition, CancellationToken token = default)
  • public void Signal()
  • public void Signal<TState>(TState state)
  • public void Signal<TState, TArgs>(TState state, Action<TState, TArgs> mutator, TArgs args)
  • public void Signal<TState>(TState state, Action<TState> mutator)
  • public Task<bool> SignalAndWaitAsync<TState>(TState state, Predicate<TState> condition, TimeSpan timeout, CancellationToken token = default)
  • public Task SignalAndWaitAsync<TState>(TState state, Predicate<TState> condition, CancellationToken token = default)
  • public Task<bool> SignalAndWaitAsync<TState, TArgs>(TState state, Action<TState, TArgs> mutator, TArgs args, Predicate<TState> condition, TimeSpan timeout, CancellationToken token = default)
  • public Task SignalAndWaitAsync<TState, TArgs>(TState state, Action<TState, TArgs> mutator, TArgs args, Predicate<TState> condition, CancellationToken token = default)
  • public Task<bool> SignalAndWaitAsync<TState>(TState state, Action<TState> mutator, Predicate<TState> condition, TimeSpan timeout, CancellationToken token = default)
  • public Task SignalAndWaitAsync<TState>(TState state, Action<TState> mutator, Predicate<TState> condition, CancellationToken token = default)
  • public Task<bool> WaitAsync(TimeSpan timeout, CancellationToken token = default)
  • public Task<bool> WaitAsync<TState>(TState state, Predicate<TState> condition, TimeSpan timeout, CancellationToken token = default)
  • public Task WaitAsync<TState>(TState state, Predicate<TState> condition, CancellationToken token = default)
• public class AsyncTrigger<TState> : QueuedSynchronizer
• 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 IAsyncEvent : ISynchronizer, IDisposable
  • ValueTask<bool> WaitAsync(TimeSpan timeout, CancellationToken token = default)
  • ValueTask WaitAsync(CancellationToken token = default)
  • Task<bool> WaitAsync(TimeSpan timeout, CancellationToken token)
• public interface ISynchronizer
  • bool HasWaiters { get; }
• public static class LinkedTokenSourceFactory
  • public static CancellationTokenSource LinkTo(this ref CancellationToken token, TimeSpan timeout)
  • public static CancellationTokenSource LinkTo(this ref CancellationToken first, TimeSpan timeout, CancellationToken second)
• public abstract class QueuedSynchronizer : Disposable, ISynchronizer
  • public ValueTask DisposeAsync()
• public abstract class Synchronizer : Disposable, ISynchronizer
  • public bool IsSet { get; }
  • public Task<bool> WaitAsync(TimeSpan timeout, CancellationToken token)
  • public Task<bool> WaitAsync<T>(Predicate<T> condition, T arg, TimeSpan timeout, CancellationToken token = default)
  • public Task WaitAsync<T>(Predicate<T> condition, T arg, CancellationToken token = default)
  • public Task<bool> WaitAsync<T1, T2>(Func<T1, T2, bool> condition, T1 arg1, T2 arg2, TimeSpan timeout, CancellationToken token = default)
  • public Task WaitAsync<T1, T2>(Func<T1, T2, bool> condition, T1 arg1, T2 arg2, CancellationToken token = default)

DotNext.Threading.Channels

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

DotNext.Threading.Tasks

• public abstract class ManualResetCompletionSource : IThreadPoolWorkItem
• public class ValueTaskCompletionSource : ManualResetCompletionSource, IValueTaskSource, ISupplier<TimeSpan, CancellationToken, ValueTask>
• public class ValueTaskCompletionSource<T> : ManualResetCompletionSource, IValueTaskSource<T>, IValueTaskSource, ISupplier<TimeSpan, CancellationToken, ValueTask<T>>, ISupplier<TimeSpan, CancellationToken, ValueTask>