DotNext.Threading by .NET Foundation and Contributors

API Diff between 4.5.0 and 5.8.0

29 Additions 34 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 Task<CancellationToken> WaitAnyAsync(this ReadOnlySpan<CancellationToken> tokens)
- 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 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 AsyncLazy<T> : ISupplier<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 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 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 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 abstract class QueuedSynchronizer<TContext> : QueuedSynchronizer
public static class Scheduler

DotNext.Threading.Channels

public sealed class PersistentChannelOptions : ChannelOptions
- public TagList MeasurementTags { 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 virtual void Cleanup()
public static class TaskCompletionPipe
public class TaskCompletionPipe<T> : IAsyncEnumerable<T> where T : Task
- public TaskCompletionPipe()
- public TaskCompletionPipe(int capacity = 0)
- public void Add(T task, object userData)
- public void Reset()
- public void Reset(int capacity = 0)
- public bool TryRead(out T task, out object userData)