DotNext.Threading by Roman Sakno

API Diff between 1.3.2 and 0.9.0

69 Additions 11 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 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> Wait(TimeSpan timeout, CancellationToken token)
public class AsyncExclusiveLock : QueuedSynchronizer
- public bool TryAcquire()
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> TryAcquire(TimeSpan timeout, CancellationToken token)
- public Task<Holder> TryAcquire(TimeSpan timeout, CancellationToken token, bool suppressCancellation = false)
- public Task<Holder> TryAcquire(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 bool TryEnterReadLock()
- public bool TryEnterUpgradeableReadLock()
- public bool TryEnterWriteLock(ref LockStamp stamp)
- public bool TryEnterWriteLock()
- 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 Acquire(bool strongLock, TimeSpan timeout)
- public Task Acquire(bool strongLock, CancellationToken token)
- public void Downgrade()
- public void Release()
- public bool TryAcquire(bool strongLock)
- public Task<bool> TryAcquire(bool strongLock, TimeSpan timeout, CancellationToken token)
- public Task<bool> TryAcquire(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)

DotNext.Threading.Channels

public abstract class PersistentChannel<TInput, TOutput> : Channel<TInput, TOutput>, IChannelWriter<TInput>, IChannel, IChannelReader<TOutput>, IDisposable
- 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()