39 lines
1.1 KiB
C#
39 lines
1.1 KiB
C#
using Microsoft.AspNetCore.Razor.Language.Intermediate;
|
|
using System.Threading.Channels;
|
|
|
|
namespace ManagementApp.AServices.ThreadManage
|
|
{
|
|
public class ConcurrentQueueThread: IConcurrentTasks
|
|
{
|
|
private readonly Channel<Func<CancellationToken, ValueTask>> queue;
|
|
public ConcurrentQueueThread(int capacity) {
|
|
var options = new BoundedChannelOptions(capacity)
|
|
{
|
|
FullMode = BoundedChannelFullMode.Wait
|
|
};
|
|
queue = Channel.CreateBounded<Func<CancellationToken, ValueTask>>(options);
|
|
}
|
|
|
|
|
|
public async ValueTask Add(Func<CancellationToken, ValueTask> value)
|
|
{
|
|
await queue.Writer.WriteAsync(value);
|
|
}
|
|
|
|
public async ValueTask<Func<CancellationToken, ValueTask>> Last(CancellationToken cancellationToken)
|
|
{
|
|
throw new NotImplementedException();
|
|
}
|
|
|
|
public async ValueTask<Func<CancellationToken, ValueTask>> First(CancellationToken cancellationToken)
|
|
{
|
|
|
|
return await queue.Reader.ReadAsync(cancellationToken);
|
|
}
|
|
|
|
|
|
|
|
}
|
|
|
|
}
|