DotNext.Threading by .NET Foundation and Contributors

<PackageReference Include="DotNext.Threading" Version="4.0.0-beta.3" />

---

API Diff between 4.0.0-beta.3 and 5.15.0

46 Additions 72 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, IDisposable
  • public bool Wait(TimeSpan timeout)
• public static class AsyncBridge
  • 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, CancellationToken token = default)
  • public static ValueTask WaitAsync(this WaitHandle handle, CancellationToken token = default)
  • public static ValueTask<bool> WaitAsync(this WaitHandle handle, TimeSpan timeout)
  • public static ValueTask<bool> WaitAsync(this WaitHandle handle)
• public class AsyncCorrelationSource<TKey, TValue>
  • public bool Pulse(TKey eventId, ref Result value)
  • public bool Pulse(TKey eventId, ref Result value, out object userData)
  • public bool Pulse(TKey eventId, TValue value)
  • public ValueTask<TValue> WaitAsync(TKey eventId, object userData, TimeSpan timeout, CancellationToken token = default)
• public class AsyncCounter : QueuedSynchronizer, IAsyncEvent, IDisposable
  • public void Increment(long delta)
• public class AsyncEventHub : QueuedSynchronizer, IResettable
• public class AsyncExclusiveLock : QueuedSynchronizer, IAsyncDisposable
  • public ValueTask StealAsync(object reason, TimeSpan timeout, CancellationToken token = default)
  • public ValueTask StealAsync(object reason = null, CancellationToken token = default)
  • public bool TryAcquire(TimeSpan timeout)
  • public ValueTask<bool> TryStealAsync(object reason, TimeSpan timeout, CancellationToken token = default)
• public class AsyncLazy<T>
  • public Task<T> Task { get; }
  • public AsyncLazy(Func<CancellationToken, Task<T>> valueFactory, bool resettable = false)
  • public AsyncLazy(Func<Task<T>> valueFactory, bool resettable = false)
  • public ConfiguredTaskAwaitable<T> ConfigureAwait(bool continueOnCapturedContext)
  • public TaskAwaiter<T> GetAwaiter()
  • public Task<T> WithCancellation(CancellationToken token)
• public struct AsyncLock : IDisposable, IEquatable<AsyncLock>, IAsyncDisposable
  • public ValueTask<Holder> TryAcquireAsync(CancellationToken token)
• public static class AsyncLockAcquisition
  • public static ValueTask<Holder> AcquireLockAsync<T>(this T obj, TimeSpan timeout, CancellationToken token = default)
  • public static ValueTask<Holder> AcquireReadLockAsync<T>(this T obj, TimeSpan timeout, 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 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 class AsyncManualResetEvent : QueuedSynchronizer, IAsyncResetEvent, IAsyncEvent, IDisposable
  • public bool Wait(TimeSpan timeout)
  • 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, IAsyncDisposable
  • public ValueTask StealWriteLockAsync(object reason, TimeSpan timeout, CancellationToken token = default)
  • public ValueTask StealWriteLockAsync(object reason = null, CancellationToken token = default)
  • public bool TryEnterReadLock(TimeSpan timeout)
  • public bool TryEnterWriteLock(TimeSpan timeout)
  • public ValueTask<bool> TryStealWriteLockAsync(object reason, TimeSpan timeout, CancellationToken token = default)
• public class AsyncTrigger : QueuedSynchronizer, IAsyncEvent, IDisposable
  • 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 Task WaitAsync<TStateMachine>(TStateMachine stateMachine, Predicate<TStateMachine> condition, CancellationToken token = default)
• public class AsyncTrigger<TState> : QueuedSynchronizer
  • public interface ITransition<TState>
  • public TState State { get; }
  • public AsyncTrigger(TState state)
  • public AsyncTrigger(TState state, int concurrencyLevel)
  • public void Signal(Action<TState> transition)
  • public void Signal<T>(Action<TState, T> transition, T arg)
  • public bool TrySignal(ITransition<TState> transition)
  • public ValueTask<bool> WaitAsync(ITransition<TState> transition, TimeSpan timeout, CancellationToken token = default)
  • public ValueTask WaitAsync(ITransition<TState> transition, CancellationToken token = default)
• public interface IAsyncEvent : IDisposable
  • bool Wait(TimeSpan timeout)
• public abstract class LinkedCancellationTokenSource : CancellationTokenSource
• public static class LinkedTokenSourceFactory
  • 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 first, CancellationToken second)
• public class PendingTaskInterruptedException : Exception
• public class QueuedSynchronizer : Disposable
  • public void Dispose(Exception reason)
  • 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

DotNext.Threading.Channels

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

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 : IThreadPoolWorkItem
  • protected const short InitialCompletionToken = -32768
  • protected object CompletionData { get; }
  • public ManualResetCompletionSourceStatus Status { get; }
  • protected virtual void CleanUp()
  • public void OnCompleted(Action<object> continuation, object state, short token, ValueTaskSourceOnCompletedFlags flags)
  • public bool TryReset(out short token)
  • public abstract bool TrySetCanceled(object completionData, CancellationToken token)
  • public abstract bool TrySetException(object completionData, Exception e)
• 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>
  • public TaskCompletionSource CreateLinkedTaskCompletionSource(object userData, TimeSpan timeout, CancellationToken token)
  • public bool TrySetCanceled(object completionData, short completionToken, CancellationToken token)
  • public bool TrySetException(object completionData, short completionToken, Exception e)
  • public bool TrySetResult(object completionData)
  • public bool TrySetResult(object completionData, short completionToken)
• public class ValueTaskCompletionSource<T> : ManualResetCompletionSource, IValueTaskSource<T>, IValueTaskSource, ISupplier<TimeSpan, CancellationToken, ValueTask<T>>, ISupplier<TimeSpan, CancellationToken, ValueTask>
  • public TaskCompletionSource<T> CreateLinkedTaskCompletionSource(object userData, TimeSpan timeout, CancellationToken token)
  • public ValueTaskSourceStatus GetStatus(short token)
  • public bool TrySetCanceled(object completionData, short completionToken, CancellationToken token)
  • public bool TrySetException(object completionData, short completionToken, Exception e)
  • public bool TrySetResult(object completionData, T value)
  • public bool TrySetResult(object completionData, short completionToken, T value)
• 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<TResult>> WhenAny<TResult>(ValueTask<TResult> task1, ValueTask<TResult> task2)
  • public static ValueTask<ValueTask> WhenAny(ValueTask task1, ValueTask task2, ValueTask task3)
  • public static ValueTask<ValueTask<TResult>> WhenAny<TResult>(ValueTask<TResult> task1, ValueTask<TResult> task2, ValueTask<TResult> task3)
  • public static ValueTask<ValueTask> WhenAny(ValueTask task1, ValueTask task2, ValueTask task3, ValueTask task4)
  • public static ValueTask<ValueTask<TResult>> WhenAny<TResult>(ValueTask<TResult> task1, ValueTask<TResult> task2, ValueTask<TResult> task3, ValueTask<TResult> task4)
  • public static ValueTask<ValueTask> WhenAny(ValueTask task1, ValueTask task2, ValueTask task3, ValueTask task4, ValueTask task5)
  • public static ValueTask<ValueTask<TResult>> WhenAny<TResult>(ValueTask<TResult> task1, ValueTask<TResult> task2, ValueTask<TResult> task3, ValueTask<TResult> task4, ValueTask<TResult> task5)