欢迎光临
我的个人博客网站

C# 并发队列ConcurrentQueue

测试函数

static async Task RunProgram()
{
var taskQueue = new ConcurrentQueue<CustomTask>();
var cts = new CancellationTokenSource();
//生成任务添加至并发队列
var taskSource = Task.Run(() => TaskProducer(taskQueue));
//同时启动四个任务处理队列中的任务
Task[] processors = new Task[4];
for(int i =1;i <= 4; i++)
{
string processId = i.ToString();
processors[i – 1] = Task.Run(
() => TaskProcessor(taskQueue, “Processor ” + processId, cts.Token)
);
}
await taskSource;
//向任务发送取消信号
cts.CancelAfter(TimeSpan.FromSeconds(2));
await Task.WhenAll(processors);
}

产生任务
static async Task TaskProducer(ConcurrentQueue<CustomTask> queue)
{
for(int i= 0;i < 20; i++)
{
await Task.Delay(50);
var workItem = new CustomTask { Id = i };
queue.Enqueue(workItem);
Console.WriteLine(“task {0} has been posted”, workItem.Id);
}
}
执行任务

static async Task TaskProcessor(ConcurrentQueue<CustomTask> queue, string name, CancellationToken token)
{
CustomTask workItem;
bool dequeueSuccesful = false;
await GetRandomDelay();
do
{
dequeueSuccesful = queue.TryDequeue(out workItem);
if (dequeueSuccesful)
{
Console.WriteLine(“task {0} has been processed by {1}”, workItem.Id, name);
}
await GetRandomDelay();
}
while (!token.IsCancellationRequested);
}

static Task GetRandomDelay()
{
int delay = new Random(DateTime.Now.Millisecond).Next(1500);
return Task.Delay(delay);
}

class CustomTask
{
public int Id { get; set; }
}

调用
static void Main(string[] args)
{
Task t = RunProgram();
t.Wait();
Console.ReadKey();
}

 

转载https://blog.csdn.net/conquerwave/article/details/50830648

赞(0) 打赏
未经允许不得转载:张拓的天空 » C# 并发队列ConcurrentQueue
分享到: 更多 (0)

评论 抢沙发

  • 昵称 (必填)
  • 邮箱 (必填)
  • 网址

专业的IT技术经验分享 更专业 更方便

联系我们本站主机

觉得文章有用就打赏一下文章作者

支付宝扫一扫打赏

微信扫一扫打赏