DotNext.Threading
by Roman Sakno
<PackageReference Include="DotNext.Threading" Version="3.0.0" />
API Diff between 3.0.0 and 4.0.0-beta.3
104 Additions 78 Removals
DotNext.Threading
-
public class AsyncAutoResetEvent : QueuedSynchronizer, IAsyncResetEvent, IAsyncEvent, ISynchronizer, IDisposable
- public AsyncAutoResetEvent(bool initialState, int concurrencyLevel)
- public ValueTask<bool> WaitAsync(TimeSpan timeout, CancellationToken token = default)
- public ValueTask WaitAsync(CancellationToken token = default)
- public Task<bool> WaitAsync(TimeSpan timeout, CancellationToken token)
-
public class AsyncBarrier : Disposable, IAsyncEvent, ISynchronizer, IDisposable
- protected virtual ValueTask PostPhase(long phase)
- protected virtual Task PostPhase(long phase)
- public ValueTask<bool> SignalAndWaitAsync(TimeSpan timeout, CancellationToken token = default)
- public ValueTask SignalAndWaitAsync(CancellationToken token = default)
- public ValueTask<bool> WaitAsync(TimeSpan timeout, CancellationToken token = default)
- public ValueTask WaitAsync(CancellationToken token = default)
- public Task<bool> SignalAndWaitAsync(TimeSpan timeout, CancellationToken token = default)
- public Task SignalAndWaitAsync(CancellationToken token)
- public Task SignalAndWaitAsync()
- public Task<bool> WaitAsync(TimeSpan timeout, CancellationToken token)
-
public static class AsyncBridge
- public static int MaxPoolSize { get; set; }
-
public class AsyncCorrelationSource<TKey, TValue>
-
public class AsyncCountdownEvent : Synchronizer, IAsyncEvent, ISynchronizer, IDisposable
- public bool IsSet { get; }
- public AsyncCountdownEvent(long initialCount, int concurrencyLevel)
- public bool Signal()
- public ValueTask<bool> WaitAsync(TimeSpan timeout, CancellationToken token = default)
- public ValueTask WaitAsync(CancellationToken token = default)
-
public class AsyncCounter : QueuedSynchronizer, IAsyncEvent, ISynchronizer, IDisposable
- public AsyncCounter(long initialValue, int concurrencyLevel)
- public bool TryDecrement()
- public ValueTask<bool> WaitAsync(TimeSpan timeout, CancellationToken token = default)
- public ValueTask WaitAsync(CancellationToken token = default)
- public Task<bool> WaitAsync(TimeSpan timeout, CancellationToken token)
-
public static class AsyncEvent
- public static Task<bool> WaitAsync(this IAsyncEvent event, TimeSpan timeout)
- public static Task WaitAsync(this IAsyncEvent event, CancellationToken token)
- public static Task WaitAsync(this IAsyncEvent event)
-
public class AsyncExclusiveLock : QueuedSynchronizer, IAsyncDisposable
- public AsyncExclusiveLock(int concurrencyLevel)
- public ValueTask AcquireAsync(TimeSpan timeout, CancellationToken token = default)
- public ValueTask AcquireAsync(CancellationToken token = default)
- public Task AcquireAsync(TimeSpan timeout, CancellationToken token = default)
- public Task AcquireAsync(CancellationToken token)
- public ValueTask DisposeAsync()
- public ValueTask<bool> TryAcquireAsync(TimeSpan timeout, CancellationToken token = default)
- public Task<bool> TryAcquireAsync(TimeSpan timeout, CancellationToken token)
- public Task<bool> TryAcquireAsync(TimeSpan timeout)
-
public struct AsyncLock : IDisposable, IEquatable<AsyncLock>, IAsyncDisposable
- public static AsyncLock ReadLock(AsyncReaderWriterLock rwLock)
- public static AsyncLock ReadLock(AsyncReaderWriterLock rwLock, bool upgradeable)
- public static AsyncLock WriteLock(AsyncReaderWriterLock rwLock, bool upgrade = false)
- public ValueTask<Holder> AcquireAsync(CancellationToken token)
- public ValueTask<Holder> AcquireAsync(TimeSpan timeout, CancellationToken token = default)
- public static AsyncLock WriteLock(AsyncReaderWriterLock rwLock)
- public Task<Holder> AcquireAsync(CancellationToken token)
- public Task<Holder> AcquireAsync(TimeSpan timeout, CancellationToken token = default)
- public ValueTask<Holder> TryAcquireAsync(TimeSpan timeout, CancellationToken token = default)
- public ValueTask<Holder> TryAcquireAsync(CancellationToken token)
- public Task<Holder> TryAcquireAsync(TimeSpan timeout, bool suppressCancellation, CancellationToken token)
- public Task<Holder> TryAcquireAsync(TimeSpan timeout, CancellationToken token = default)
- public Task<Holder> TryAcquireAsync(CancellationToken token)
-
public static class AsyncLockAcquisition
- public static ValueTask<Holder> AcquireLockAsync<T>(this T obj, TimeSpan timeout)
- public static ValueTask<Holder> AcquireLockAsync<T>(this T obj, CancellationToken token)
- public static ValueTask<Holder> AcquireReadLockAsync<T>(this T obj, TimeSpan timeout)
- public static ValueTask<Holder> AcquireReadLockAsync<T>(this T obj, CancellationToken token)
- public static ValueTask<Holder> AcquireWriteLockAsync<T>(this T obj, TimeSpan timeout)
- public static ValueTask<Holder> AcquireWriteLockAsync<T>(this T obj, CancellationToken token)
- 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 static Task<Holder> AcquireLockAsync<T>(this T obj, TimeSpan timeout)
- public static Task<Holder> AcquireLockAsync<T>(this T obj, CancellationToken token)
- public static Task<Holder> AcquireReadLockAsync<T>(this T obj, TimeSpan timeout)
- public static Task<Holder> AcquireReadLockAsync<T>(this T obj, CancellationToken token)
- public static Task<Holder> AcquireUpgradeableReadLockAsync<T>(this T obj, TimeSpan timeout)
- public static Task<Holder> AcquireUpgradeableReadLockAsync<T>(this T obj, CancellationToken token)
- public static Task<Holder> AcquireWriteLockAsync<T>(this T obj, TimeSpan timeout)
- public static Task<Holder> AcquireWriteLockAsync<T>(this T obj, CancellationToken token)
-
public class AsyncManualResetEvent : Synchronizer, IAsyncResetEvent, IAsyncEvent, ISynchronizer, IDisposable
- public bool IsSet { get; }
- public AsyncManualResetEvent(bool initialState, int concurrencyLevel)
- public ValueTask<bool> WaitAsync(TimeSpan timeout, CancellationToken token = default)
- public ValueTask WaitAsync(CancellationToken token = default)
- 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 bool IsUpgradeableReadLockHeld { get; }
- public AsyncReaderWriterLock(int concurrencyLevel)
- public void DowngradeFromWriteLock()
- public ValueTask EnterReadLockAsync(TimeSpan timeout, CancellationToken token = default)
- public ValueTask EnterReadLockAsync(CancellationToken token = default)
- public ValueTask EnterWriteLockAsync(CancellationToken token = default)
- public ValueTask EnterWriteLockAsync(TimeSpan timeout, CancellationToken token = default)
- public void Release()
- public ValueTask DisposeAsync()
- public Task EnterReadLockAsync(CancellationToken token)
- public Task EnterReadLockAsync(TimeSpan timeout, CancellationToken token = default)
- public Task EnterUpgradeableReadLockAsync(CancellationToken token)
- public Task EnterUpgradeableReadLockAsync(TimeSpan timeout, CancellationToken token = default)
- public Task EnterWriteLockAsync(CancellationToken token)
- public Task EnterWriteLockAsync(TimeSpan timeout, CancellationToken token = default)
- public void ExitReadLock()
- public void ExitUpgradeableReadLock()
- public void ExitWriteLock()
- public ValueTask<bool> TryEnterReadLockAsync(TimeSpan timeout, CancellationToken token = default)
- public Task<bool> TryEnterReadLockAsync(TimeSpan timeout, CancellationToken token)
- public Task<bool> TryEnterReadLockAsync(TimeSpan timeout)
- public bool TryEnterUpgradeableReadLock()
- public Task<bool> TryEnterUpgradeableReadLockAsync(TimeSpan timeout, CancellationToken token)
- public Task<bool> TryEnterUpgradeableReadLockAsync(TimeSpan timeout)
- public ValueTask<bool> TryEnterWriteLockAsync(TimeSpan timeout, CancellationToken token = default)
- public Task<bool> TryEnterWriteLockAsync(TimeSpan timeout, CancellationToken token)
- public Task<bool> TryEnterWriteLockAsync(TimeSpan timeout)
- public bool TryUpgradeToWriteLock()
- public ValueTask<bool> TryUpgradeToWriteLockAsync(TimeSpan timeout, CancellationToken token = default)
- public ValueTask UpgradeToWriteLockAsync(CancellationToken token = default)
- public ValueTask UpgradeToWriteLockAsync(TimeSpan timeout, CancellationToken token = default)
-
public class AsyncSharedLock : QueuedSynchronizer, IAsyncDisposable
- public AsyncSharedLock(long concurrencyLevel, bool limitedConcurrency = true)
- public ValueTask AcquireAsync(bool strongLock, TimeSpan timeout, CancellationToken token = default)
- public ValueTask AcquireAsync(bool strongLock, CancellationToken token = default)
- public AsyncSharedLock(long concurrencyLevel)
- public Task AcquireAsync(bool strongLock, TimeSpan timeout, CancellationToken token = default)
- public Task AcquireAsync(bool strongLock, CancellationToken token)
- public ValueTask DisposeAsync()
- public ValueTask<bool> TryAcquireAsync(bool strongLock, TimeSpan timeout, CancellationToken token = default)
- public Task<bool> TryAcquireAsync(bool strongLock, TimeSpan timeout, CancellationToken token)
- public Task<bool> TryAcquireAsync(bool strongLock, TimeSpan timeout)
-
public class AsyncTimer : Disposable, IAsyncDisposable
- public bool IsRunning { get; }
- public AsyncTimer(Func<CancellationToken, Task<bool>> callback)
- public ValueTask DisposeAsync()
- public bool Start(TimeSpan dueTime, TimeSpan period, CancellationToken token = default)
- public bool Start(TimeSpan period, CancellationToken token = default)
- public Task<bool> StopAsync()
-
public class AsyncTrigger : QueuedSynchronizer, IAsyncEvent, ISynchronizer, IDisposable
- public AsyncTrigger(int concurrencyLevel)
- public bool Signal(bool resumeAll = false)
- public ValueTask<bool> SignalAndWaitAsync(bool resumeAll, bool throwOnEmptyQueue, TimeSpan timeout, CancellationToken token = default)
- public ValueTask SignalAndWaitAsync(bool resumeAll, bool throwOnEmptyQueue, CancellationToken token = default)
- public ValueTask<bool> WaitAsync(TimeSpan timeout, CancellationToken token = default)
- public ValueTask WaitAsync(CancellationToken token = default)
- public Task WaitAsync<TStateMachine>(TStateMachine stateMachine, Predicate<TStateMachine> condition, CancellationToken token = default)
- 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 class AsyncTrigger<TState> : QueuedSynchronizer
-
public interface IAsyncEvent : ISynchronizer, IDisposable
- ValueTask<bool> WaitAsync(TimeSpan timeout, CancellationToken token = default)
- ValueTask WaitAsync(CancellationToken token = default)
- Task<bool> WaitAsync(TimeSpan timeout, CancellationToken token)
-
public interface ISynchronizer
- bool HasAnticipants { get; }
-
public static class LinkedTokenSourceFactory
- public static CancellationTokenSource LinkTo(this ref CancellationToken token, TimeSpan timeout)
- public static CancellationTokenSource LinkTo(this ref CancellationToken first, TimeSpan timeout, CancellationToken second)
-
public abstract class QueuedSynchronizer : Disposable, ISynchronizer
- public ValueTask DisposeAsync()
-
public abstract class Synchronizer : Disposable, ISynchronizer
- public bool IsSet { get; }
- public Task<bool> WaitAsync(TimeSpan timeout, CancellationToken token)
- 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 abstract class ManualResetCompletionSource : IThreadPoolWorkItem
-
public class ValueTaskCompletionSource : ManualResetCompletionSource, IValueTaskSource, ISupplier<TimeSpan, CancellationToken, ValueTask>
-
public class ValueTaskCompletionSource<T> : ManualResetCompletionSource, IValueTaskSource<T>, IValueTaskSource, ISupplier<TimeSpan, CancellationToken, ValueTask<T>>, ISupplier<TimeSpan, CancellationToken, ValueTask>
-
public abstract class Future : IFuture, INotifyCompletion, IValueTaskSource
- public interface IAwaiter
- public bool IsCompleted { get; }
- protected Future(bool runContinuationsAsynchronously = true, bool continueOnCapturedContext = false)
- public ValueTask AsTask()
- protected void Complete(Exception e = null)
- protected void GetResult()
- public void OnCompleted(Action callback)
-
public abstract class Future<TResult> : IFuture, INotifyCompletion, IValueTaskSource<TResult>
- public interface IAwaiter<TResult>
- public bool IsCompleted { get; }
- protected Future(bool runContinuationsAsynchronously = true, bool continueOnCapturedContext = false)
- public ValueTask<TResult> AsTask()
- protected void Complete(Result<TResult> e)
- protected TResult GetResult()
- public void OnCompleted(Action callback)