DotNext.Threading
by Roman Sakno
<PackageReference Include="DotNext.Threading" Version="2.2.0" />
API Diff between 2.2.0 and 1.2.3
54 Additions 36 Removals
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 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 Task<bool> TryAcquireAsync(TimeSpan timeout, CancellationToken token)
- public Task<bool> TryAcquireAsync(TimeSpan timeout)
-
public struct AsyncLock : IDisposable, IEquatable<AsyncLock>
- 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, bool suppressCancellation = false)
- public Task<Holder> TryAcquire(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 class AsyncReaderWriterLock : QueuedSynchronizer
- 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> TryEnterReadLockAsync(TimeSpan timeout, CancellationToken token)
- public Task<bool> TryEnterReadLockAsync(TimeSpan timeout)
- public Task<bool> TryEnterUpgradeableReadLock(TimeSpan timeout)
- public Task<bool> TryEnterUpgradeableReadLockAsync(TimeSpan timeout, CancellationToken token)
- public Task<bool> TryEnterUpgradeableReadLockAsync(TimeSpan timeout)
- public Task<bool> TryEnterWriteLock(TimeSpan timeout, CancellationToken token)
- public Task<bool> TryEnterWriteLock(TimeSpan timeout)
- public Task<bool> TryEnterWriteLockAsync(TimeSpan timeout, CancellationToken token)
- public Task<bool> TryEnterWriteLockAsync(TimeSpan timeout)
-
public class AsyncSharedLock : QueuedSynchronizer
- public Task Acquire(bool strongLock, TimeSpan timeout)
- public Task Acquire(bool strongLock, CancellationToken token)
- public Task AcquireAsync(bool strongLock, TimeSpan timeout, CancellationToken token = default)
- public Task AcquireAsync(bool strongLock, CancellationToken token)
- public Task<bool> TryAcquire(bool strongLock, TimeSpan timeout, CancellationToken token)
- public Task<bool> TryAcquire(bool strongLock, TimeSpan timeout)
- public Task<bool> TryAcquireAsync(bool strongLock, TimeSpan timeout, CancellationToken token)
- public Task<bool> TryAcquireAsync(bool strongLock, TimeSpan timeout)
-
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()