DotNext.Threading by Roman Sakno

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

---

API Diff between 1.3.2 and 0.14.0

40 Additions 0 Removals

DotNext.Threading

• 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 struct AsyncLock : IDisposable, IEquatable<AsyncLock>
  • public static AsyncLock Exclusive(AsyncSharedLock lock)
  • public static AsyncLock Weak(AsyncSharedLock lock)
• 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 ConcurrentObjectPool<T> : Disposable
  • 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()