DotNext.Threading by Roman Sakno

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

---

API Diff between 2.10.1 and 2.0.0

42 Additions 4 Removals

DotNext.Threading

• public class AsyncExchanger<T> : Disposable, IAsyncDisposable
  • public bool IsTerminated { get; }
  • public AsyncExchanger()
  • public ValueTask DisposeAsync()
  • public ValueTask<T> ExchangeAsync(T value, TimeSpan timeout, CancellationToken token = default)
  • public ValueTask<T> ExchangeAsync(T value, CancellationToken token = default)
  • public void Terminate(Exception exception = null)
  • public bool TryExchange(ref T value)
• public class AsyncExclusiveLock : QueuedSynchronizer, IAsyncDisposable
  • public ValueTask DisposeAsync()
• public struct AsyncLock : IDisposable, IEquatable<AsyncLock>, IAsyncDisposable
  • public ValueTask DisposeAsync()
• public class AsyncReaderWriterLock : QueuedSynchronizer, IAsyncDisposable
  • public ValueTask DisposeAsync()
• public class AsyncSharedLock : QueuedSynchronizer, IAsyncDisposable
  • public ValueTask DisposeAsync()
• public class AsyncTimer : Disposable, IAsyncDisposable
  • public ValueTask DisposeAsync()
• public class AsyncTrigger : QueuedSynchronizer, IAsyncEvent, ISynchronizer, IDisposable
  • public AsyncTrigger()
  • public void Signal()
  • public void Signal<TState>(TState state)
  • public void Signal<TState, TArgs>(TState state, Action<TState, TArgs> mutator, TArgs args)
  • public void Signal<TState>(TState state, Action<TState> mutator)
  • 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 SignalAndWaitAsync<TState>(TState state, Predicate<TState> condition, 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 SignalAndWaitAsync<TState, TArgs>(TState state, Action<TState, TArgs> mutator, TArgs args, Predicate<TState> condition, CancellationToken token = default)
  • public Task<bool> SignalAndWaitAsync<TState>(TState state, Action<TState> mutator, Predicate<TState> condition, TimeSpan timeout, CancellationToken token = default)
  • public Task SignalAndWaitAsync<TState>(TState state, Action<TState> mutator, Predicate<TState> condition, 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 sealed class ExchangeTerminatedException : Exception
• public static class LinkedTokenSourceFactory
  • public static CancellationTokenSource LinkTo(this ref CancellationToken first, CancellationToken second)
• public abstract class QueuedSynchronizer : Disposable, ISynchronizer
  • public void CancelSuspendedCallers(CancellationToken token)
• public abstract class Synchronizer : Disposable, ISynchronizer
  • public Task<bool> WaitAsync<T>(Predicate<T> condition, T arg, TimeSpan timeout, CancellationToken token = default)
  • public Task WaitAsync<T>(Predicate<T> condition, T arg, CancellationToken token = default)
  • public Task<bool> WaitAsync<T1, T2>(Func<T1, T2, bool> condition, T1 arg1, T2 arg2, TimeSpan timeout, CancellationToken token = default)
  • public Task WaitAsync<T1, T2>(Func<T1, T2, bool> condition, T1 arg1, T2 arg2, CancellationToken token = default)

DotNext.Threading.Tasks

• public static class ValueTaskSynchronization
  • public static ValueTask<ValueTask<R>> WhenAny<R>(ValueTask<R> task1, ValueTask<R> task2)
  • public static ValueTask<ValueTask<TResult>> WhenAny<TResult>(ValueTask<TResult> task1, ValueTask<TResult> task2)
  • public static ValueTask<ValueTask<R>> WhenAny<R>(ValueTask<R> task1, ValueTask<R> task2, ValueTask<R> task3)
  • public static ValueTask<ValueTask<TResult>> WhenAny<TResult>(ValueTask<TResult> task1, ValueTask<TResult> task2, ValueTask<TResult> task3)
  • public static ValueTask<ValueTask<R>> WhenAny<R>(ValueTask<R> task1, ValueTask<R> task2, ValueTask<R> task3, ValueTask<R> task4)
  • public static ValueTask<ValueTask<TResult>> WhenAny<TResult>(ValueTask<TResult> task1, ValueTask<TResult> task2, ValueTask<TResult> task3, ValueTask<TResult> task4)
  • public static ValueTask<ValueTask<R>> WhenAny<R>(ValueTask<R> task1, ValueTask<R> task2, ValueTask<R> task3, ValueTask<R> task4, ValueTask<R> task5)
  • public static ValueTask<ValueTask<TResult>> WhenAny<TResult>(ValueTask<TResult> task1, ValueTask<TResult> task2, ValueTask<TResult> task3, ValueTask<TResult> task4, ValueTask<TResult> task5)