DotNext.Threading by .NET Foundation and Contributors

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

---

API Diff between 3.3.1 and 3.0.0

48 Additions 0 Removals

DotNext.Threading

• public class AsyncCorrelationSource<TKey, TValue>
  • public AsyncCorrelationSource(long concurrencyLevel, IEqualityComparer<TKey> comparer = null)
  • public void ClearCache()
  • public bool Pulse(TKey eventId, TValue value)
  • public void PulseAll(TValue value)
  • public void PulseAll(Exception e)
  • public void PulseAll(CancellationToken token)
  • public ValueTask<TValue> WaitAsync(TKey eventId, TimeSpan timeout, CancellationToken token = default)
  • public ValueTask<TValue> WaitAsync(TKey eventId, CancellationToken token = default)
• public class AsyncCounter : QueuedSynchronizer, IAsyncEvent, ISynchronizer, IDisposable
  • public bool TryDecrement()
• public static class AsyncLockAcquisition
  • 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 class AsyncTrigger : QueuedSynchronizer, IAsyncEvent, ISynchronizer, IDisposable
  • public bool EnsureState<TState>(TState state, Predicate<TState> condition)
  • public void Signal<TState>(TState state, bool fairness)
  • public void Signal<TState, TArgs>(TState state, Action<TState, TArgs> mutator, TArgs args, bool fairness)
  • public void Signal<TState>(TState state, Action<TState> mutator, bool fairness)
  • 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, bool fairness, 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, bool fairness, 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, bool fairness, CancellationToken token = default)

DotNext.Threading.Tasks

• public abstract class ManualResetCompletionSource : IThreadPoolWorkItem
  • protected virtual void AfterConsumed()
  • public short Reset()
  • public abstract bool TrySetCanceled(CancellationToken token)
  • public abstract bool TrySetException(Exception e)
• public abstract class ManualResetCompletionSource<T> : ManualResetCompletionSource where T : struct, IEquatable<T>
  • public T CreateTask(TimeSpan timeout, CancellationToken token)
• public class ValueTaskCompletionSource : ManualResetCompletionSource<ValueTask>, IValueTaskSource
  • public ValueTaskCompletionSource(bool runContinuationsAsynchronously = true)
  • protected virtual void BeforeCompleted(Exception e)
  • protected virtual Exception OnCanceled(CancellationToken token)
  • protected virtual Exception OnTimeout()
  • public bool TrySetCanceled(short completionToken, CancellationToken token)
  • public bool TrySetException(short completionToken, Exception e)
  • public bool TrySetResult()
  • public bool TrySetResult(short completionToken)
• public class ValueTaskCompletionSource<T> : ManualResetCompletionSource<ValueTask<T>>, IValueTaskSource<T>
  • public ValueTaskCompletionSource(bool runContinuationsAsynchronously = true)
  • protected virtual void BeforeCompleted(Result<T> result)
  • protected virtual Result<T> OnCanceled(CancellationToken token)
  • protected virtual Result<T> OnTimeout()
  • public bool TrySetCanceled(short completionToken, CancellationToken token)
  • public bool TrySetException(short completionToken, Exception e)
  • public bool TrySetResult(T value)
  • public bool TrySetResult(short completionToken, T value)