DotNext.Threading by Roman Sakno

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

---

API Diff between 2.2.0 and 0.9.0

99 Additions 41 Removals

DotNext.Runtime.CompilerServices

• public sealed class CancellationTokenFuture : Future<Task>, IAwaiter, IFuture, INotifyCompletion
  • public IAwaiter GetAwaiter()
• public sealed class WaitHandleFuture : Future<Task<bool>>, IAwaiter<bool>, IFuture, INotifyCompletion
  • public IAwaiter<bool> GetAwaiter()

DotNext.Threading

• public class AsyncAutoResetEvent : QueuedSynchronizer, IAsyncResetEvent, IAsyncEvent, ISynchronizer, IDisposable
  • public Task<bool> Wait(TimeSpan timeout, CancellationToken token)
  • public Task<bool> WaitAsync(TimeSpan timeout, CancellationToken token)
• public class AsyncBarrier : Disposable, IAsyncEvent, ISynchronizer, IDisposable
  • public Task<bool> SignalAndWait(TimeSpan timeout, CancellationToken token)
  • public Task SignalAndWait(CancellationToken token)
  • public Task<bool> SignalAndWait(TimeSpan timeout)
  • public Task SignalAndWait()
  • public Task<bool> Wait(TimeSpan timeout, CancellationToken token)
  • 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 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 class AsyncCounter : QueuedSynchronizer, IAsyncEvent, ISynchronizer, IDisposable
  • public long Value { get; }
  • public AsyncCounter(long initialValue = 0)
  • public void Increment()
  • public Task<bool> WaitAsync(TimeSpan timeout, CancellationToken token)
• public static class AsyncEvent
  • public static Task<bool> Wait(this IAsyncEvent event, TimeSpan timeout)
  • public static Task Wait(this IAsyncEvent event, CancellationToken token)
  • public static Task Wait(this IAsyncEvent event)
  • 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
  • public Task Acquire(TimeSpan timeout)
  • public Task Acquire(CancellationToken token)
  • public Task AcquireAsync(TimeSpan timeout, CancellationToken token = default)
  • public Task AcquireAsync(CancellationToken token)
  • public Task<bool> TryAcquire(TimeSpan timeout, CancellationToken token)
  • public Task<bool> TryAcquire(TimeSpan timeout)
  • public bool TryAcquire()
  • public Task<bool> TryAcquireAsync(TimeSpan timeout, CancellationToken token)
  • public Task<bool> TryAcquireAsync(TimeSpan timeout)
• public class AsyncLazy<T>
  • public bool IsValueCreated { get; }
  • public Task<T> Task { get; }
  • public Result<T>? Value { get; }
  • public AsyncLazy(T value)
  • public AsyncLazy(ValueFunc<Task<T>> valueFactory, bool resettable = false)
  • public AsyncLazy(Func<Task<T>> valueFactory, bool resettable = false)
  • public ConfiguredTaskAwaitable<T> ConfigureAwait(bool continueOnCapturedContext)
  • public TaskAwaiter<T> GetAwaiter()
  • public bool Reset()
• public struct AsyncLock : IDisposable, IEquatable<AsyncLock>
  • public static AsyncLock Exclusive(AsyncSharedLock lock)
  • public static AsyncLock Weak(AsyncSharedLock lock)
  • public Task<Holder> Acquire(CancellationToken token)
  • public Task<Holder> Acquire(TimeSpan timeout)
  • public Task<Holder> AcquireAsync(CancellationToken token)
  • public Task<Holder> AcquireAsync(TimeSpan timeout, CancellationToken token = default)
  • public Task<Holder> TryAcquire(TimeSpan timeout)
  • public Task<Holder> TryAcquire(TimeSpan timeout, 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 Task<Holder> AcquireLock(this AsyncExclusiveLock lock, CancellationToken token)
  • public static Task<Holder> AcquireLock(this AsyncExclusiveLock lock, TimeSpan timeout)
  • public static Task<Holder> AcquireLockAsync(this SemaphoreSlim semaphore, CancellationToken token)
  • public static Task<Holder> AcquireLockAsync(this SemaphoreSlim semaphore, TimeSpan timeout)
  • public static Task<Holder> AcquireReadLock(this AsyncReaderWriterLock rwLock, TimeSpan timeout)
  • public static Task<Holder> AcquireReadLock(this AsyncReaderWriterLock rwLock, CancellationToken token)
  • public static Task<Holder> AcquireUpgradeableReadLock(this AsyncReaderWriterLock rwLock, TimeSpan timeout)
  • public static Task<Holder> AcquireUpgradeableReadLock(this AsyncReaderWriterLock rwLock, CancellationToken token)
  • public static Task<Holder> AcquireWriteLock(this AsyncReaderWriterLock rwLock, TimeSpan timeout)
  • public static Task<Holder> AcquireWriteLock(this AsyncReaderWriterLock rwLock, CancellationToken token)
• public class AsyncManualResetEvent : Synchronizer, IAsyncResetEvent, IAsyncEvent, ISynchronizer, IDisposable
  • public bool Set(bool autoReset)
• public class AsyncReaderWriterLock : QueuedSynchronizer
  • public struct LockStamp : IEquatable<LockStamp>
  • public Task EnterReadLock(CancellationToken token)
  • public Task EnterReadLock(TimeSpan timeout)
  • public Task EnterUpgradeableReadLock(CancellationToken token)
  • public Task EnterUpgradeableReadLock(TimeSpan timeout)
  • public Task EnterWriteLock(CancellationToken token)
  • public Task EnterWriteLock(TimeSpan timeout)
  • 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 Task<bool> TryEnterReadLock(TimeSpan timeout, CancellationToken token)
  • public Task<bool> TryEnterReadLock(TimeSpan timeout)
  • public Task<bool> TryEnterUpgradeableReadLock(TimeSpan timeout, CancellationToken token)
  • public Task<bool> TryEnterUpgradeableReadLock(TimeSpan timeout)
  • public Task<bool> TryEnterWriteLock(TimeSpan timeout, CancellationToken token)
  • public Task<bool> TryEnterWriteLock(TimeSpan timeout)
  • public bool TryEnterReadLock()
  • 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 bool TryEnterWriteLock(ref LockStamp stamp)
  • public bool TryEnterWriteLock()
  • public Task<bool> TryEnterWriteLockAsync(TimeSpan timeout, CancellationToken token)
  • public Task<bool> TryEnterWriteLockAsync(TimeSpan timeout)
  • public LockStamp TryOptimisticRead()
• public class AsyncSharedLock : QueuedSynchronizer
  • public long ConcurrencyLevel { get; }
  • public bool IsLockHeld { get; }
  • public long RemainingCount { get; }
  • public AsyncSharedLock(long concurrencyLevel)
  • public Task AcquireAsync(bool strongLock, TimeSpan timeout, CancellationToken token = default)
  • public Task AcquireAsync(bool strongLock, CancellationToken token)
  • public void Downgrade()
  • public void Release()
  • public bool TryAcquire(bool strongLock)
  • public Task<bool> TryAcquireAsync(bool strongLock, TimeSpan timeout, CancellationToken token)
  • public Task<bool> TryAcquireAsync(bool strongLock, TimeSpan timeout)
• public class AsyncTimer : Disposable
  • public bool IsRunning { get; }
  • public AsyncTimer(ValueFunc<CancellationToken, Task<bool>> callback)
  • public AsyncTimer(Func<CancellationToken, Task<bool>> callback)
  • public bool Start(TimeSpan dueTime, TimeSpan period, CancellationToken token = default)
  • public bool Start(TimeSpan period, CancellationToken token = default)
  • public Task<bool> StopAsync()
• public class ConcurrentObjectPool<T> : Disposable
  • public ConcurrentObjectPool(int capacity, ValueFunc<T> factory)
  • public IRental<T> Rent(CancellationToken token)
• public interface IAsyncEvent : ISynchronizer, IDisposable
  • Task<bool> Wait(TimeSpan timeout, CancellationToken token)
  • Task<bool> WaitAsync(TimeSpan timeout, CancellationToken token)
• public abstract class Synchronizer : Disposable, ISynchronizer
  • public Task<bool> Wait(TimeSpan timeout, CancellationToken token)
  • public Task<bool> WaitAsync(TimeSpan timeout, CancellationToken token)

DotNext.Threading.Channels

• public abstract class PersistentChannel<TInput, TOutput> : Channel<TInput, TOutput>, IChannelWriter<TInput>, IChannel, IChannelReader<TOutput>, IDisposable
  • public long RemainingCount { get; }
  • public double Throughput { get; }
  • protected PersistentChannel(PersistentChannelOptions options)
  • protected abstract ValueTask<TOutput> DeserializeAsync(Stream input, CancellationToken token)
  • protected virtual void Dispose(bool disposing)
  • public void Dispose()
  • protected abstract ValueTask SerializeAsync(TInput input, Stream output, CancellationToken token)
• public sealed class PersistentChannelOptions : ChannelOptions
  • public int BufferSize { get; set; }
  • public long InitialPartitionSize { get; set; }
  • public string Location { get; set; }
  • public int PartitionCapacity { get; set; }
  • public PersistentChannelOptions()