DotNext.Threading by Roman Sakno

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

---

API Diff between 1.3.0 and 1.1.0

27 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 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 void Downgrade()
  • public bool TryAcquire(bool strongLock)

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()