DotNext.Threading by Roman Sakno

API Diff between 3.0.0 and 2.4.0

40 Additions 9 Removals

DotNext.Runtime.CompilerServices

public sealed class CancellationTokenFuture : Future<Task>, IAwaiter, IFuture, INotifyCompletion
public sealed class WaitHandleFuture : Future<Task<bool>>, IAwaiter<bool>, IFuture, INotifyCompletion

DotNext.Threading

public static class AsyncBridge
- public static CancellationTokenFuture WaitAsync(this CancellationToken token, bool completeAsCanceled = false)
- public static WaitHandleFuture WaitAsync(this WaitHandle handle, TimeSpan timeout)
- public static WaitHandleFuture WaitAsync(this WaitHandle handle)
- public static ValueTask WaitAsync(this CancellationToken token, bool completeAsCanceled = false)
- public static ValueTask<bool> WaitAsync(this WaitHandle handle, TimeSpan timeout)
- public static ValueTask<bool> WaitAsync(this WaitHandle handle)
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 class AsyncLazy<T>
- public AsyncLazy(ValueFunc<Task<T>> valueFactory, bool resettable = false)
public struct AsyncLock : IDisposable, IEquatable<AsyncLock>, IAsyncDisposable
- public ValueTask DisposeAsync()
public class AsyncReaderWriterLock : QueuedSynchronizer, IAsyncDisposable
- public ValueTask DisposeAsync()
- public bool Validate(ref LockStamp stamp)
public class AsyncSharedLock : QueuedSynchronizer, IAsyncDisposable
- public bool IsStrongLockHeld { get; }
- public ValueTask DisposeAsync()
public class AsyncTimer : Disposable, IAsyncDisposable
- public AsyncTimer(ValueFunc<CancellationToken, Task<bool>> callback)
- public ValueTask DisposeAsync()
public class AsyncTrigger : QueuedSynchronizer, IAsyncEvent, ISynchronizer, IDisposable
- public Task<bool> SignalAndWaitAsync(TimeSpan timeout, CancellationToken token = default)
- public Task SignalAndWaitAsync(CancellationToken token = default)
public class ConcurrentObjectPool<T> : Disposable
public sealed class ExchangeTerminatedException : Exception
public interface ISynchronizer
- bool HasWaiters { get; }
- bool HasAnticipants { get; }

DotNext.Threading.Channels

public sealed class PersistentChannelOptions : ChannelOptions
- public IncrementingEventCounter ReadRateCounter { get; set; }
- public IncrementingEventCounter WriteRateCounter { get; set; }

DotNext.Threading.Tasks

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)