DotNext.Threading by .NET Foundation and Contributors

API Diff between 4.8.0 and 4.4.0

22 Additions 3 Removals

DotNext.Threading

public class AsyncExclusiveLock : QueuedSynchronizer, IAsyncDisposable
- public ValueTask StealAsync(object reason, TimeSpan timeout, CancellationToken token = default)
- public ValueTask StealAsync(object reason = null, CancellationToken token = default)
- public ValueTask<bool> TryStealAsync(object reason, TimeSpan timeout, CancellationToken token = default)
public class AsyncReaderWriterLock : QueuedSynchronizer, IAsyncDisposable
- public ValueTask StealWriteLockAsync(object reason, TimeSpan timeout, CancellationToken token = default)
- public ValueTask StealWriteLockAsync(object reason = null, CancellationToken token = default)
- public ValueTask<bool> TryStealWriteLockAsync(object reason, TimeSpan timeout, CancellationToken token = default)
public abstract class LinkedCancellationTokenSource : CancellationTokenSource
- public CancellationToken CancellationOrigin { get; }
public static class LinkedTokenSourceFactory
- public static CancellationTokenSource LinkTo(this ref CancellationToken first, CancellationToken second)
- public static LinkedCancellationTokenSource LinkTo(this ref CancellationToken first, CancellationToken second)
public class PendingTaskInterruptedException : Exception
- public object Reason { get; set; }
- public PendingTaskInterruptedException(string message = null, Exception innerException = null)
public static class Scheduler
- public abstract class DelayedTask
- public abstract class DelayedTask<TResult> : DelayedTask
- public sealed class DelayedTaskCanceledException : OperationCanceledException
- public static DelayedTask ScheduleAsync<TArgs>(Func<TArgs, CancellationToken, ValueTask> callback, TArgs args, TimeSpan delay, CancellationToken token = default)
- public static DelayedTask<TResult> ScheduleAsync<TArgs, TResult>(Func<TArgs, CancellationToken, ValueTask<TResult>> callback, TArgs args, TimeSpan delay, CancellationToken token = default)

DotNext.Threading.Tasks

public static class TaskCompletionPipe
- public static IAsyncEnumerable<T> GetConsumer<T>(this TaskCompletionPipe<Task<T>> pipe)
public class TaskCompletionPipe<T> : IDynamicInterfaceCastable, IAsyncEnumerable<T> where T : Task
- public TaskCompletionPipe(int capacity = 0)
- public TaskCompletionPipe()
- public void Reset(int capacity = 0)
- public void Reset()