DotNext.Threading by Roman Sakno

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

---

API Diff between 0.8.0 and 5.16.0

84 Additions 108 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, ISynchronizer, IDisposable
  • public AsyncAutoResetEvent(bool initialState, int concurrencyLevel)
  • public bool Wait(TimeSpan timeout)
  • public ValueTask<bool> WaitAsync(TimeSpan timeout, CancellationToken token = default)
  • public ValueTask WaitAsync(CancellationToken token = default)
  • public Task<bool> Wait(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> SignalAndWait(TimeSpan timeout, CancellationToken token)
  • public Task SignalAndWait(CancellationToken token)
  • public Task<bool> SignalAndWait(TimeSpan timeout)
  • public Task SignalAndWait()
  • public Task<bool> Wait(TimeSpan timeout, CancellationToken token)
• public static class AsyncBridge
• 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, IDisposable, IResettable
• public class AsyncEventHub : QueuedSynchronizer, IResettable
• public class AsyncExchanger<T> : Disposable, IAsyncDisposable
• public static class AsyncEvent
  • public static Task<bool> Wait(this IAsyncEvent event, TimeSpan timeout)
  • public static Task Wait(this IAsyncEvent event, CancellationToken token)
  • public static Task Wait(this IAsyncEvent event)
• public sealed class AsyncExclusiveLock : QueuedSynchronizer
  • public AsyncExclusiveLock(int concurrencyLevel)
  • public ValueTask AcquireAsync(TimeSpan timeout, CancellationToken token = default)
  • public ValueTask AcquireAsync(CancellationToken token = default)
  • public Task Acquire(TimeSpan timeout)
  • public Task Acquire(CancellationToken token)
  • public ValueTask StealAsync(object reason, TimeSpan timeout, CancellationToken token = default)
  • public ValueTask StealAsync(object reason = null, CancellationToken token = default)
  • public bool TryAcquire()
  • public bool TryAcquire(TimeSpan timeout, CancellationToken token = default)
  • public ValueTask<bool> TryAcquireAsync(TimeSpan timeout, CancellationToken token = default)
  • public ValueTask<bool> TryStealAsync(object reason, TimeSpan timeout, CancellationToken token = default)
  • public Task<bool> TryAcquire(TimeSpan timeout, CancellationToken token)
  • public Task<bool> TryAcquire(TimeSpan timeout)
• public class AsyncLazy<T> : ISupplier<CancellationToken, Task<T>>, IFunctional<Func<CancellationToken, Task<T>>>, IResettable
• public struct AsyncLock : IDisposable, IEquatable<AsyncLock>
  • public static AsyncLock Exclusive(AsyncSharedLock lock)
  • public static AsyncLock ReadLock(AsyncReaderWriterLock rwLock)
  • public static AsyncLock ReadLock(AsyncReaderWriterLock rwLock, bool upgradeable)
  • public static AsyncLock Weak(AsyncSharedLock lock)
  • 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> Acquire(CancellationToken token)
  • public Task<Holder> Acquire(TimeSpan timeout)
  • public ValueTask DisposeAsync()
  • public ValueTask<Holder> TryAcquireAsync(TimeSpan timeout, CancellationToken token = default)
  • public Task<Holder> TryAcquire(TimeSpan timeout)
  • public Task<Holder> TryAcquire(TimeSpan timeout, CancellationToken token)
• public static class AsyncLockAcquisition
  • public static ValueTask<Holder> AcquireLockAsync<T>(T obj, TimeSpan timeout)
  • public static ValueTask<Holder> AcquireLockAsync<T>(this T obj, CancellationToken token = default)
  • public static ValueTask<Holder> AcquireLockAsync<T>(this T obj, TimeSpan timeout, CancellationToken token = default)
  • public static ValueTask<Holder> AcquireReadLockAsync<T>(T obj, TimeSpan timeout)
  • public static ValueTask<Holder> AcquireReadLockAsync<T>(this T obj, CancellationToken token = default)
  • public static ValueTask<Holder> AcquireReadLockAsync<T>(this T obj, TimeSpan timeout, CancellationToken token = default)
  • public static ValueTask<Holder> AcquireWriteLockAsync<T>(T obj, TimeSpan timeout)
  • public static ValueTask<Holder> AcquireWriteLockAsync<T>(this T obj, 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 static Task<Holder> AcquireLock(this AsyncExclusiveLock lock, CancellationToken token)
  • public static Task<Holder> AcquireLock(this AsyncExclusiveLock lock, TimeSpan timeout)
  • public static Task<Holder> AcquireLockAsync(this SemaphoreSlim semaphore, CancellationToken token)
  • public static Task<Holder> AcquireLockAsync(this SemaphoreSlim semaphore, TimeSpan timeout)
  • 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> AcquireReadLock(this AsyncReaderWriterLock rwLock, TimeSpan timeout)
  • public static Task<Holder> AcquireReadLock(this AsyncReaderWriterLock rwLock, 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> AcquireUpgradeableReadLock(this AsyncReaderWriterLock rwLock, TimeSpan timeout)
  • public static Task<Holder> AcquireUpgradeableReadLock(this AsyncReaderWriterLock rwLock, 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> AcquireWriteLock(this AsyncReaderWriterLock rwLock, TimeSpan timeout)
  • public static Task<Holder> AcquireWriteLock(this AsyncReaderWriterLock rwLock, 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 bool Set(bool autoReset)
  • public bool Wait(TimeSpan timeout)
  • public ValueTask<bool> WaitAsync(TimeSpan timeout, CancellationToken token = default)
  • public ValueTask WaitAsync(CancellationToken token = default)
• public class AsyncReaderWriterLock : QueuedSynchronizer
  • public struct LockStamp : IEquatable<LockStamp>
  • 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 ValueTask StealWriteLockAsync(object reason, TimeSpan timeout, CancellationToken token = default)
  • public ValueTask StealWriteLockAsync(object reason = null, CancellationToken token = default)
  • public bool TryEnterReadLock()
  • public bool TryEnterReadLock(TimeSpan timeout, CancellationToken token = default)
  • public ValueTask<bool> TryEnterReadLockAsync(TimeSpan timeout, CancellationToken token = default)
  • public bool TryEnterWriteLock(ref LockStamp stamp)
  • public bool TryEnterWriteLock()
  • public bool TryEnterWriteLock(TimeSpan timeout, CancellationToken token = default)
  • public ValueTask<bool> TryEnterWriteLockAsync(TimeSpan timeout, CancellationToken token = default)
  • public LockStamp TryOptimisticRead()
  • public ValueTask<bool> TryStealWriteLockAsync(object reason, TimeSpan timeout, CancellationToken token = default)
  • 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 Task EnterReadLock(CancellationToken token)
  • public Task EnterReadLock(TimeSpan timeout)
  • public Task EnterUpgradeableReadLock(CancellationToken token)
  • public Task EnterUpgradeableReadLock(TimeSpan timeout)
  • public Task EnterWriteLock(CancellationToken token)
  • public Task EnterWriteLock(TimeSpan timeout)
  • public void ExitReadLock()
  • public void ExitUpgradeableReadLock()
  • public void ExitWriteLock()
  • public Task<bool> TryEnterReadLock(TimeSpan timeout, CancellationToken token)
  • public Task<bool> TryEnterReadLock(TimeSpan timeout)
  • public Task<bool> TryEnterUpgradeableReadLock(TimeSpan timeout, CancellationToken token)
  • public Task<bool> TryEnterUpgradeableReadLock(TimeSpan timeout)
  • public Task<bool> TryEnterWriteLock(TimeSpan timeout, CancellationToken token)
  • public Task<bool> TryEnterWriteLock(TimeSpan timeout)
• public class AsyncSharedLock : QueuedSynchronizer, IAsyncDisposable
• public class AsyncTrigger : QueuedSynchronizer, IAsyncEvent, IDisposable, IResettable
• public sealed class ExchangeTerminatedException : PendingTaskInterruptedException
• public class ConcurrentObjectPool<T>
  • public struct Rental<T>
  • protected readonly IReadOnlyList<T> objects
  • public ConcurrentObjectPool(IList<T> objects)
  • public Rental<T> Rent()
• public interface IAsyncEvent : ISynchronizer, IDisposable
  • bool Wait(TimeSpan timeout)
  • ValueTask<bool> WaitAsync(TimeSpan timeout, CancellationToken token = default)
  • ValueTask WaitAsync(CancellationToken token = default)
  • Task<bool> Wait(TimeSpan timeout, CancellationToken token)
• public abstract class LinkedCancellationTokenSource : CancellationTokenSource
• public static class LinkedTokenSourceFactory
• public class PendingTaskInterruptedException : Exception
• public interface ISynchronizer
  • bool HasWaiters { get; }
• public abstract class QueuedSynchronizer : Disposable, ISynchronizer
  • public void CancelSuspendedCallers(CancellationToken token)
  • public void Dispose(Exception reason)
  • public ValueTask DisposeAsync()
  • public IReadOnlyList<object> GetSuspendedCallers()
  • public void SetCallerInformation(object information)
  • public void TrackSuspendedCallers(Func<object> callerInfoProvider = null)
• public abstract class QueuedSynchronizer<TContext> : QueuedSynchronizer
• public static class Scheduler
• public abstract class Synchronizer : Disposable, ISynchronizer
  • public bool IsSet { get; }
  • public Task<bool> Wait(TimeSpan timeout, CancellationToken token)

DotNext.Threading.Channels

• public abstract class PersistentChannel<TInput, TOutput> : Channel<TInput, TOutput>, IChannelWriter<TInput>, IChannel, IChannelReader<TOutput>, IDisposable
• public sealed class PersistentChannelOptions : ChannelOptions

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
• public enum ManualResetCompletionSourceStatus
• public static class TaskCompletionPipe
• public class TaskCompletionPipe<T> : IAsyncEnumerable<T>, IResettable where T : Task
• public class TaskQueue<T> : IAsyncEnumerable<T>, IResettable where T : Task
• public class ValueTaskCompletionSource : ManualResetCompletionSource, IValueTaskSource, ISupplier<TimeSpan, CancellationToken, ValueTask>, IFunctional<Func<TimeSpan, CancellationToken, ValueTask>>
• 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 static class ValueTaskSynchronization
  • public static ValueTask WhenAll(ValueTask task1, ValueTask task2)
  • public static ValueTask<ValueTuple<T1, T2>> WhenAll<T1, T2>(ValueTask<T1> task1, ValueTask<T2> task2)
  • public static ValueTask WhenAll(ValueTask task1, ValueTask task2, ValueTask task3)
  • public static ValueTask<ValueTuple<T1, T2, T3>> WhenAll<T1, T2, T3>(ValueTask<T1> task1, ValueTask<T2> task2, ValueTask<T3> task3)
  • public static ValueTask WhenAll(ValueTask task1, ValueTask task2, ValueTask task3, ValueTask task4)
  • public static ValueTask<ValueTuple<T1, T2, T3, T4>> WhenAll<T1, T2, T3, T4>(ValueTask<T1> task1, ValueTask<T2> task2, ValueTask<T3> task3, ValueTask<T4> task4)
  • public static ValueTask WhenAll(ValueTask task1, ValueTask task2, ValueTask task3, ValueTask task4, ValueTask task5)
  • public static ValueTask<ValueTuple<T1, T2, T3, T4, T5>> WhenAll<T1, T2, T3, T4, T5>(ValueTask<T1> task1, ValueTask<T2> task2, ValueTask<T3> task3, ValueTask<T4> task4, ValueTask<T5> task5)
  • public static ValueTask<ValueTask> WhenAny(ValueTask task1, ValueTask task2)
  • public static ValueTask<ValueTask<R>> WhenAny<R>(ValueTask<R> task1, ValueTask<R> task2)
  • public static ValueTask<ValueTask> WhenAny(ValueTask task1, ValueTask task2, ValueTask task3)
  • public static ValueTask<ValueTask<R>> WhenAny<R>(ValueTask<R> task1, ValueTask<R> task2, ValueTask<R> task3)
  • public static ValueTask<ValueTask> WhenAny(ValueTask task1, ValueTask task2, ValueTask task3, ValueTask task4)
  • public static ValueTask<ValueTask<R>> WhenAny<R>(ValueTask<R> task1, ValueTask<R> task2, ValueTask<R> task3, ValueTask<R> task4)
  • public static ValueTask<ValueTask> WhenAny(ValueTask task1, ValueTask task2, ValueTask task3, ValueTask task4, ValueTask task5)
  • public static ValueTask<ValueTask<R>> WhenAny<R>(ValueTask<R> task1, ValueTask<R> task2, ValueTask<R> task3, ValueTask<R> task4, ValueTask<R> task5)