DotNext.Threading by .NET Foundation and Contributors

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

---

API Diff between 4.14.0 and 4.2.0

42 Additions 7 Removals

DotNext.Threading

• 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 ValueTask<bool> TryStealAsync(object reason, TimeSpan timeout, CancellationToken token = default)
• public class AsyncManualResetEvent : QueuedSynchronizer, IAsyncResetEvent, IAsyncEvent, IDisposable
  • 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 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 class AsyncTrigger<TState> : QueuedSynchronizer
  • public void Signal()
• 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 LinkedCancellationTokenSource LinkTo(this ref CancellationToken first, CancellationToken second)
• public class PendingTaskInterruptedException : Exception
  • public object Reason { get; set; }
  • public PendingTaskInterruptedException(string message = null, Exception innerException = null)
• 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 bool ReliableEnumeration { get; set; }

DotNext.Threading.Tasks

• public abstract class ManualResetCompletionSource
  • protected const short InitialCompletionToken = -32768
  • protected virtual void Cleanup()
• public static class TaskCompletionPipe
  • public static IAsyncEnumerable<T> GetConsumer<T>(this TaskCompletionPipe<Task<T>> pipe)
• public class TaskCompletionPipe<T> : IDynamicInterfaceCastable, IAsyncEnumerable<T>, IResettable where T : Task
  • public TaskCompletionPipe(int capacity = 0)
  • public TaskCompletionPipe()
  • public void Add(T task, object userData)
  • public void Reset(int capacity = 0)
  • public void Reset()
  • public bool TryRead(out T task, out object userData)