DotNext.Threading by .NET Foundation and Contributors

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

---

API Diff between 4.12.3 and 5.10.0

24 Additions 26 Removals

DotNext.Collections.Concurrent

• public struct IndexPool : ISupplier<int>, IFunctional<Func<int>>, IConsumer<int>, IFunctional<Action<int>>, IReadOnlyCollection<int>, IEnumerable<int>, IEnumerable, IResettable

DotNext.Threading

• 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 AsyncLazy<T> : ISupplier<CancellationToken, Task<T>>, IFunctional<Func<CancellationToken, Task<T>>>
  • 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 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 AsyncTrigger<TState> : QueuedSynchronizer
  • public interface ITransition<TState>
  • public TState State { get; }
  • public AsyncTrigger(TState state)
  • public AsyncTrigger(TState state, int concurrencyLevel)
  • public void Signal()
  • 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 static class LinkedTokenSourceFactory
  • public static bool CausedBy(this OperationCanceledException e, LinkedCancellationTokenSource source, CancellationToken token)

DotNext.Threading.Channels

• public sealed class PersistentChannelOptions : ChannelOptions
  • 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 static class TaskCompletionPipe
  • public struct Consumer<T> : IAsyncEnumerable<T>
  • public static IAsyncEnumerable<T> Create<T>(ReadOnlySpan<T> tasks) where T : Task
  • public static Consumer<T> GetConsumer<T>(this TaskCompletionPipe<Task<T>> pipe)
  • public static Consumer<T> GetConsumer<T>(this ReadOnlySpan<Task<T>> tasks)
  • public static IAsyncEnumerable<T> GetConsumer<T>(this TaskCompletionPipe<Task<T>> pipe)
• public class TaskCompletionPipe<T> : IDynamicInterfaceCastable, IAsyncEnumerable<T>, IResettable where T : Task
  • public Task Completion { get; }
  • public bool IsCompletionTaskSupported { get; set; }
  • public void Add(T task, object userData)
  • public void Add(ReadOnlySpan<T> tasks, bool complete = false, object userData = null)
  • public bool TryRead(out T task, out object userData)
• public class TaskQueue<T> : IAsyncEnumerable<T>, IResettable where T : Task