DotNext.Threading
by .NET Foundation and Contributors
<PackageReference Include="DotNext.Threading" Version="5.4.0" />
API Diff between 5.4.0 and 4.9.0
37 Additions 16 Removals
DotNext.Collections.Concurrent
-
public struct IndexPool : ISupplier<int>, IFunctional<Func<int>>, IConsumer<int>, IFunctional<Action<int>>, IReadOnlyCollection<int>, IEnumerable<int>, IEnumerable, IResettable
- public struct Enumerator
- public static int Capacity { get; }
- public static int MaxValue { get; }
- public int Count { get; }
- public bool IsEmpty { get; set; }
- public IndexPool()
- public IndexPool(int maxValue)
- public bool Contains(int value)
- public Enumerator GetEnumerator()
- public void Reset()
- public void Return(int value)
- public void Return(ReadOnlySpan<int> indices)
- public int Take()
- public int Take(Span<int> indices)
- public bool TryPeek(out int result)
- public bool TryTake(out int result)
DotNext.Threading
-
public class AsyncLazy<T> : ISupplier<CancellationToken, Task<T>>, IFunctional<Func<CancellationToken, Task<T>>>, IResettable
- 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> 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, IResettable
- 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 AsyncTrigger : QueuedSynchronizer, IAsyncEvent, IDisposable, IResettable
- 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 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)
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.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 struct Consumer<T> : IAsyncEnumerable<T>
- public static Consumer<T> GetConsumer<T>(this TaskCompletionPipe<Task<T>> pipe)
- public class TaskCompletionPipe<T> : IAsyncEnumerable<T>, IResettable where T : Task