DotNext.Threading by .NET Foundation and Contributors

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

---

API Diff between 5.12.0 and 3.3.0

297 Additions 99 Removals

DotNext.Collections.Concurrent

• public struct IndexPool : ISupplier<int>, IFunctional<Func<int>>, IConsumer<int>, IFunctional<Action<int>>, IReadOnlyCollection<int>, IEnumerable<int>, IEnumerable, IResettable
  • public struct Enumerator
  • public static int Capacity { get; }
  • public static int MaxValue { get; }
  • public int Count { get; }
  • public bool IsEmpty { get; set; }
  • public IndexPool()
  • public IndexPool(int maxValue)
  • public bool Contains(int value)
  • public Enumerator GetEnumerator()
  • public void Reset()
  • public void Return(int value)
  • public void Return(ReadOnlySpan<int> indices)
  • public int Take()
  • public int Take(Span<int> indices)
  • public bool TryPeek(out int result)
  • public bool TryTake(out int result)

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

DotNext.Threading

• public class AsyncAutoResetEvent : QueuedSynchronizer, IAsyncResetEvent, IAsyncEvent, IDisposable, IResettable
  • public AsyncAutoResetEvent(bool initialState, int concurrencyLevel)
  • public Task<bool> WaitAsync(TimeSpan timeout, CancellationToken token)
  • public ValueTask<bool> WaitAsync(TimeSpan timeout, CancellationToken token = default)
  • public ValueTask WaitAsync(CancellationToken token = default)
• public class AsyncBarrier : Disposable, IAsyncEvent, IDisposable, IResettable
  • protected virtual Task PostPhase(long phase)
  • protected virtual ValueTask PostPhase(long phase)
  • 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 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 static class AsyncBridge
  • public static int MaxPoolSize { get; set; }
  • public static CancellationToken AsCancellationToken(this Task task)
  • public static CancellationToken AsCancellationToken(this Task task, out Func disposeTokenSource)
  • public static Task<CancellationToken> WaitAnyAsync(this ReadOnlySpan<CancellationToken> tokens)
  • public static Task<CancellationToken> WaitAnyAsync(this ReadOnlySpan<CancellationToken> tokens, out Func interruption)
  • public static ValueTask<bool> WaitAsync(this WaitHandle handle, TimeSpan timeout)
  • public static ValueTask<bool> WaitAsync(this WaitHandle handle)
  • public static ValueTask<bool> WaitAsync(this WaitHandle handle, TimeSpan timeout, CancellationToken token = default)
  • public static ValueTask WaitAsync(this WaitHandle handle, CancellationToken token = default)
• public class AsyncCorrelationSource<TKey, TValue>
  • public AsyncCorrelationSource(long concurrencyLevel, IEqualityComparer<TKey> comparer = null)
  • public bool Pulse(TKey eventId, TValue value)
  • public AsyncCorrelationSource(int concurrencyLevel, IEqualityComparer<TKey> comparer = null)
  • public bool Pulse(TKey eventId, ref Result value)
  • public bool Pulse(TKey eventId, ref Result value, out object userData)
  • public ValueTask<TValue> WaitAsync(TKey eventId, object userData, TimeSpan timeout, CancellationToken token = default)
• public class AsyncCountdownEvent : QueuedSynchronizer, IAsyncEvent, IDisposable, IResettable
  • 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 AsyncCounter(long initialValue, int concurrencyLevel)
  • public void Increment(long delta)
  • public Task<bool> WaitAsync(TimeSpan timeout, CancellationToken token)
  • public ValueTask<bool> WaitAsync(TimeSpan timeout, CancellationToken token = default)
  • public ValueTask WaitAsync(CancellationToken token = default)
• public static class AsyncEvent
• public class AsyncEventHub : IResettable
  • public int Count { get; }
  • public AsyncEventHub(int count)
  • public void CancelSuspendedCallers(CancellationToken token)
  • public void CaptureState(Span<bool> states)
  • public bool Pulse(int eventIndex)
  • 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 void Reset()
  • public bool ResetAndPulse(int eventIndex)
  • 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 class AsyncExclusiveLock : QueuedSynchronizer, IAsyncDisposable
  • public AsyncExclusiveLock(int concurrencyLevel)
  • public Task AcquireAsync(TimeSpan timeout, CancellationToken token = default)
  • public Task AcquireAsync(CancellationToken token)
  • public ValueTask DisposeAsync()
  • public ValueTask AcquireAsync(TimeSpan timeout, CancellationToken token = default)
  • public ValueTask AcquireAsync(CancellationToken token = default)
  • public ValueTask StealAsync(object reason, TimeSpan timeout, CancellationToken token = default)
  • public ValueTask StealAsync(object reason = null, CancellationToken token = default)
  • public Task<bool> TryAcquireAsync(TimeSpan timeout, CancellationToken token)
  • public Task<bool> TryAcquireAsync(TimeSpan timeout)
  • public ValueTask<bool> TryAcquireAsync(TimeSpan timeout, CancellationToken token = default)
  • public ValueTask<bool> TryStealAsync(object reason, TimeSpan timeout, CancellationToken token = default)
• public class AsyncLazy<T> : ISupplier<CancellationToken, Task<T>>, IFunctional<Func<CancellationToken, Task<T>>>, IResettable
  • public Task<T> Task { get; }
  • public AsyncLazy(Func<Task<T>> valueFactory, bool resettable = false)
  • public ConfiguredTaskAwaitable<T> ConfigureAwait(bool continueOnCapturedContext)
  • public TaskAwaiter<T> GetAwaiter()
  • public AsyncLazy(Func<CancellationToken, Task<T>> valueFactory, bool resettable = false)
  • public Task<T> WithCancellation(CancellationToken token)
• public struct AsyncLock : IDisposable, IEquatable<AsyncLock>, IAsyncDisposable
  • public static AsyncLock ReadLock(AsyncReaderWriterLock rwLock, bool upgradeable)
  • public static AsyncLock ReadLock(AsyncReaderWriterLock rwLock)
  • public static AsyncLock WriteLock(AsyncReaderWriterLock rwLock)
  • public Task<Holder> AcquireAsync(CancellationToken token)
  • public Task<Holder> AcquireAsync(TimeSpan timeout, CancellationToken token = default)
  • 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 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 ValueTask<Holder> TryAcquireAsync(TimeSpan timeout, CancellationToken token = default)
• public static class AsyncLockAcquisition
  • 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 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 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 class AsyncManualResetEvent : QueuedSynchronizer, IAsyncResetEvent, IAsyncEvent, IDisposable, IResettable
  • 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 class AsyncReaderWriterLock : QueuedSynchronizer, IAsyncDisposable
  • public bool IsUpgradeableReadLockHeld { get; }
  • public AsyncReaderWriterLock(int concurrencyLevel)
  • public ValueTask DisposeAsync()
  • 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 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 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> TryEnterReadLockAsync(TimeSpan timeout, CancellationToken token = default)
  • public Task<bool> TryEnterWriteLockAsync(TimeSpan timeout, CancellationToken token)
  • public Task<bool> TryEnterWriteLockAsync(TimeSpan timeout)
  • public ValueTask<bool> TryEnterWriteLockAsync(TimeSpan timeout, CancellationToken token = default)
  • 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 class AsyncSharedLock : QueuedSynchronizer, IAsyncDisposable
  • public AsyncSharedLock(long concurrencyLevel)
  • public Task AcquireAsync(bool strongLock, TimeSpan timeout, CancellationToken token = default)
  • public Task AcquireAsync(bool strongLock, CancellationToken token)
  • public ValueTask DisposeAsync()
  • 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 Task<bool> TryAcquireAsync(bool strongLock, TimeSpan timeout, CancellationToken token)
  • public Task<bool> TryAcquireAsync(bool strongLock, TimeSpan timeout)
  • public ValueTask<bool> TryAcquireAsync(bool strongLock, TimeSpan timeout, CancellationToken token = default)
• public class AsyncTimer : Disposable, IAsyncDisposable
• public class AsyncTrigger : QueuedSynchronizer, IAsyncEvent, IDisposable, IResettable
  • public bool EnsureState<TState>(TState state, Predicate<TState> condition)
  • public void Signal()
  • public void Signal<TState>(TState state)
  • public void Signal<TState>(TState state, bool fairness)
  • public void Signal<TState, TArgs>(TState state, Action<TState, TArgs> mutator, TArgs args)
  • public void Signal<TState, TArgs>(TState state, Action<TState, TArgs> mutator, TArgs args, bool fairness)
  • public void Signal<TState>(TState state, Action<TState> mutator)
  • 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, 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, 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, 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, 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, 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, CancellationToken token = default)
  • public Task SignalAndWaitAsync<TState>(TState state, Action<TState> mutator, Predicate<TState> condition, bool fairness, 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 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> SpinWaitAsync<TCondition>(TCondition condition, TimeSpan timeout, CancellationToken token = default) where TCondition : ISupplier<bool>
  • public ValueTask SpinWaitAsync<TCondition>(TCondition condition, CancellationToken token = default) where TCondition : ISupplier<bool>
  • public ValueTask<bool> WaitAsync(TimeSpan timeout, CancellationToken token = default)
  • public ValueTask WaitAsync(CancellationToken token = default)
• public interface IAsyncEvent : IDisposable, IResettable
  • Task<bool> WaitAsync(TimeSpan timeout, CancellationToken token)
  • ValueTask<bool> WaitAsync(TimeSpan timeout, CancellationToken token = default)
  • ValueTask WaitAsync(CancellationToken token = default)
• public interface ISynchronizer
• public abstract class LinkedCancellationTokenSource : CancellationTokenSource
  • public CancellationToken CancellationOrigin { get; }
• public static class LinkedTokenSourceFactory
  • public static CancellationTokenSource LinkTo(this ref CancellationToken first, CancellationToken second)
  • public static bool CausedBy(this OperationCanceledException e, LinkedCancellationTokenSource source, CancellationToken token)
  • public static LinkedCancellationTokenSource LinkTo(this ref CancellationToken first, CancellationToken second)
  • public static CancellationTokenSource LinkTo(this ref CancellationToken token, TimeSpan timeout)
  • public static CancellationTokenSource LinkTo(this ref CancellationToken first, TimeSpan timeout, CancellationToken second)
• public class PendingTaskInterruptedException : Exception
  • public object Reason { get; set; }
  • public PendingTaskInterruptedException(string message = null, Exception innerException = null)
• public class QueuedSynchronizer : Disposable
  • 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 Synchronizer : Disposable, ISynchronizer
• public abstract class QueuedSynchronizer<TContext> : QueuedSynchronizer
  • protected QueuedSynchronizer(int? concurrencyLevel)
  • protected ValueTask AcquireAsync(TContext context, TimeSpan timeout, CancellationToken token)
  • protected ValueTask AcquireAsync(TContext context, CancellationToken token)
  • protected virtual void AcquireCore(TContext context)
  • protected abstract bool CanAcquire(TContext context)
  • protected void Release()
  • protected void Release(TContext context)
  • protected virtual void ReleaseCore(TContext context)
  • protected bool TryAcquire(TContext context)
  • protected ValueTask<bool> TryAcquireAsync(TContext context, TimeSpan timeout, CancellationToken token)
• public static class Scheduler
  • public abstract class DelayedTask
  • public abstract class DelayedTask<TResult> : DelayedTask
  • public sealed class DelayedTaskCanceledException : OperationCanceledException
  • public static DelayedTask ScheduleAsync<TArgs>(Func<TArgs, CancellationToken, ValueTask> callback, TArgs args, TimeSpan delay, CancellationToken token = default)
  • public static DelayedTask<TResult> ScheduleAsync<TArgs, TResult>(Func<TArgs, CancellationToken, ValueTask<TResult>> callback, TArgs args, TimeSpan delay, CancellationToken token = default)

DotNext.Threading.Channels

• public sealed class PersistentChannelOptions : ChannelOptions
  • public TagList MeasurementTags { get; set; }
  • public IncrementingEventCounter ReadRateCounter { get; set; }
  • public IncrementingEventCounter WriteRateCounter { get; set; }
  • public bool ReliableEnumeration { get; set; }

DotNext.Threading.Leases

• public abstract class LeaseConsumer : Disposable, IAsyncDisposable
  • protected struct AcquisitionResult
  • public double ClockDriftBound { get; set; }
  • public Timeout& modreq(System.Runtime.InteropServices.InAttribute) Expiration { get; }
  • public LeaseIdentity& modreq(System.Runtime.InteropServices.InAttribute) LeaseId { get; }
  • public CancellationToken Token { get; }
  • protected LeaseConsumer(TimeProvider provider = null)
  • public ValueTask AcquireAsync(TimeSpan pauseDuration, Random pauseRandomizer = null, CancellationToken token = default)
  • public ValueTask DisposeAsync()
  • public Task<TResult> ExecuteAsync<TResult>(Func<CancellationToken, Task<TResult>> worker, CancellationToken token = default)
  • public ValueTask<bool> ReleaseAsync(CancellationToken token = default)
  • protected abstract ValueTask<LeaseIdentity?> ReleaseCoreAsync(LeaseIdentity identity, CancellationToken token)
  • public ValueTask<bool> TryAcquireAsync(CancellationToken token = default)
  • protected abstract ValueTask<AcquisitionResult?> TryAcquireCoreAsync(CancellationToken token = default)
  • public ValueTask<bool> TryRenewAsync(CancellationToken token = default)
  • protected abstract ValueTask<AcquisitionResult?> TryRenewCoreAsync(LeaseIdentity identity, CancellationToken token)
• public struct LeaseIdentity : IEquatable<LeaseIdentity>
  • public const ulong InitialVersion = 0
  • public Guid Id { get; set; }
  • public ulong Version { get; set; }
  • public static bool op_Equality(ref LeaseIdentity x, ref LeaseIdentity y)
  • public static bool op_Inequality(ref LeaseIdentity x, ref LeaseIdentity y)
  • public static bool op_LeftShift(ref LeaseIdentity x, ref LeaseIdentity y)
  • public static bool op_RightShift(ref LeaseIdentity x, ref LeaseIdentity y)
  • public bool Equals(LeaseIdentity other)
  • public bool Precedes(ref LeaseIdentity other)
• public abstract class LeaseProvider<TMetadata> : Disposable
  • public struct AcquisitionResult<TMetadata>
  • public struct State<TMetadata>
  • protected CancellationToken LifetimeToken { get; }
  • public TimeSpan TimeToLive { get; }
  • protected LeaseProvider(TimeSpan ttl, TimeProvider provider = null)
  • public ValueTask<AcquisitionResult<TMetadata>> AcquireAsync<TArg>(TArg arg, Func<TArg, TMetadata, CancellationToken, ValueTask<TMetadata>> updater, CancellationToken token = default)
  • public ValueTask<AcquisitionResult<TMetadata>> AcquireAsync(CancellationToken token = default)
  • protected abstract ValueTask<State<TMetadata>> GetStateAsync(CancellationToken token)
  • public ValueTask<LeaseIdentity?> ReleaseAsync<TArg>(LeaseIdentity identity, TArg arg, Func<TArg, TMetadata, CancellationToken, ValueTask<TMetadata>> updater, CancellationToken token = default)
  • public ValueTask<LeaseIdentity?> ReleaseAsync(LeaseIdentity identity, CancellationToken token = default)
  • public ValueTask<AcquisitionResult<TMetadata>?> TryAcquireAsync<TArg>(TArg arg, Func<TArg, TMetadata, CancellationToken, ValueTask<TMetadata>> updater, CancellationToken token = default)
  • public ValueTask<AcquisitionResult<TMetadata>?> TryAcquireAsync(CancellationToken token = default)
  • public ValueTask<AcquisitionResult<TMetadata>?> TryAcquireOrRenewAsync<TArg>(LeaseIdentity identity, TArg arg, Func<TArg, TMetadata, CancellationToken, ValueTask<TMetadata>> updater, CancellationToken token = default)
  • public ValueTask<AcquisitionResult<TMetadata>?> TryAcquireOrRenewAsync(LeaseIdentity identity, CancellationToken token = default)
  • public ValueTask<AcquisitionResult<TMetadata>?> TryRenewAsync<TArg>(LeaseIdentity identity, bool reacquire, TArg arg, Func<TArg, TMetadata, CancellationToken, ValueTask<TMetadata>> updater, CancellationToken token = default)
  • public ValueTask<AcquisitionResult<TMetadata>?> TryRenewAsync(LeaseIdentity identity, bool reacquire, CancellationToken token = default)
  • protected abstract ValueTask<bool> TryUpdateStateAsync(State<TMetadata> state, CancellationToken token)
  • public ValueTask<LeaseIdentity> UnsafeReleaseAsync<TArg>(TArg arg, Func<TArg, TMetadata, CancellationToken, ValueTask<TMetadata>> updater, CancellationToken token = default)
  • public ValueTask<LeaseIdentity> UnsafeReleaseAsync(CancellationToken token = default)
  • public ValueTask<LeaseIdentity?> UnsafeTryReleaseAsync<TArg>(TArg arg, Func<TArg, TMetadata, CancellationToken, ValueTask<TMetadata>> updater, CancellationToken token = default)
  • public ValueTask<LeaseIdentity?> UnsafeTryReleaseAsync(CancellationToken token = default)

DotNext.Threading.Tasks

• public abstract class Future : IFuture, INotifyCompletion, IValueTaskSource
• public abstract class Future<TResult> : IFuture, INotifyCompletion, IValueTaskSource<TResult>
• public static class ValueTaskSynchronization
• public abstract class ManualResetCompletionSource
  • protected const short InitialCompletionToken = -32768
  • protected object CompletionData { get; }
  • public bool IsCompleted { get; }
  • public ManualResetCompletionSourceStatus Status { get; }
  • protected virtual void AfterConsumed()
  • protected virtual void CleanUp()
  • public short Reset()
  • public bool TryReset(out short token)
  • public bool TrySetCanceled(CancellationToken token)
  • public abstract bool TrySetCanceled(object completionData, CancellationToken token)
  • public bool TrySetException(Exception e)
  • public abstract bool TrySetException(object completionData, Exception e)
• public enum ManualResetCompletionSourceStatus
  • Activated = 1
  • Consumed = 3
  • WaitForActivation = 0
  • WaitForConsumption = 2
• public static class TaskCompletionPipe
  • public struct Consumer<T> : IAsyncEnumerable<T>
  • 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 TaskCompletionPipe()
  • public void Add(T task)
  • public void Add(T task, object userData)
  • public void Add(ReadOnlySpan<T> tasks, bool complete = false, object userData = null)
  • public void Complete()
  • public IAsyncEnumerator<T> GetAsyncEnumerator(CancellationToken token)
  • public void Reset()
  • public bool TryRead(out T task)
  • public bool TryRead(out T task, out object userData)
  • public ValueTask<bool> WaitToReadAsync(TimeSpan timeout, CancellationToken token = default)
  • public ValueTask<bool> WaitToReadAsync(CancellationToken token = default)
• 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 : ManualResetCompletionSource, IValueTaskSource, ISupplier<TimeSpan, CancellationToken, ValueTask>, IFunctional<Func<TimeSpan, CancellationToken, ValueTask>>
  • public ValueTaskCompletionSource(bool runContinuationsAsynchronously = true)
  • public TaskCompletionSource CreateLinkedTaskCompletionSource(object userData, TimeSpan timeout, CancellationToken token)
  • public ValueTask CreateTask(TimeSpan timeout, CancellationToken token)
  • protected virtual Exception OnCanceled(CancellationToken token)
  • protected virtual Exception OnTimeout()
  • public bool TrySetCanceled(short completionToken, CancellationToken token)
  • public bool TrySetCanceled(object completionData, short completionToken, CancellationToken token)
  • public bool TrySetException(short completionToken, Exception e)
  • public bool TrySetException(object completionData, short completionToken, Exception e)
  • public bool TrySetResult()
  • public bool TrySetResult(object completionData)
  • public bool TrySetResult(short completionToken)
  • public bool TrySetResult(object completionData, short completionToken)
• 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 ValueTaskCompletionSource(bool runContinuationsAsynchronously = true)
  • public TaskCompletionSource<T> CreateLinkedTaskCompletionSource(object userData, TimeSpan timeout, CancellationToken token)
  • public ValueTask<T> CreateTask(TimeSpan timeout, CancellationToken token)
  • protected virtual Result<T> OnCanceled(CancellationToken token)
  • protected virtual Result<T> OnTimeout()
  • public bool TrySetCanceled(short completionToken, CancellationToken token)
  • public bool TrySetCanceled(object completionData, short completionToken, CancellationToken token)
  • public bool TrySetException(short completionToken, Exception e)
  • public bool TrySetException(object completionData, short completionToken, Exception e)
  • public bool TrySetResult(T value)
  • public bool TrySetResult(object completionData, T value)
  • public bool TrySetResult(short completionToken, T value)
  • public bool TrySetResult(object completionData, short completionToken, T value)