当前位置: 首页 > wzjs >正文

小型公众号开发成都自动seo

小型公众号开发,成都自动seo,苏州做网站的公司哪家好,js做网站框架在 C# 中&#xff0c;可以使用 Task 和 ConcurrentQueue 来构建一个 异步任务队列&#xff0c;确保任务按照 FIFO&#xff08;先进先出&#xff09;顺序执行&#xff0c;并支持并发安全。 设计方案 任务队列 (ConcurrentQueue<Func>) 存储异步任务&#xff08;每个任务都…

在 C# 中,可以使用 Task 和 ConcurrentQueue 来构建一个 异步任务队列,确保任务按照 FIFO(先进先出)顺序执行,并支持并发安全。

设计方案
任务队列 (ConcurrentQueue<Func>)
存储异步任务(每个任务都是 Func)
任务按 FIFO 方式执行

后台任务处理器
使用 SemaphoreSlim 控制并发
任务会按照顺序执行,避免阻塞主线程
存在并行执行任务

支持功能
EnqueueTask(Func):将新任务加入队列
自动处理任务:后台异步循环,按顺序执行任务
队列管理(支持动态添加任务、取消任务)
支持返回值和无返回值两种类型

代码示例

using System;
using System.Collections.Concurrent;
using System.Threading;
using System.Threading.Tasks;public class AsyncTaskQueue
{private readonly ConcurrentQueue<TaskItem> _taskQueue = new();private readonly SemaphoreSlim _semaphore = new(1, 1); // 控制顺序任务执行private bool _isProcessing = false; // 任务处理状态private enum TaskType{Sequential,  // 顺序执行任务Parallel     // 并行执行任务}private class TaskItem{public Func<Task> TaskFunc { get; }public TaskType Type { get; }public TaskItem(Func<Task> taskFunc, TaskType type){TaskFunc = taskFunc;Type = type;}}/// <summary>/// 添加 **顺序执行** 的无返回值任务到队列/// </summary>public void EnqueueTask(Func<Task> taskFunc){_taskQueue.Enqueue(new TaskItem(taskFunc, TaskType.Sequential));ProcessQueue();}/// <summary>/// 添加 **顺序执行** 的有返回值任务到队列,并返回 `Task<T>`/// </summary>public Task<T> EnqueueTask<T>(Func<Task<T>> taskFunc){var tcs = new TaskCompletionSource<T>();_taskQueue.Enqueue(new TaskItem(async () =>{try{T result = await taskFunc();tcs.SetResult(result);}catch (Exception ex){tcs.SetException(ex);}}, TaskType.Sequential));ProcessQueue();return tcs.Task;}/// <summary>/// 立即执行 **并行任务**(无返回值)/// </summary>public void EnqueueParallelTask(Func<Task> taskFunc){_taskQueue.Enqueue(new TaskItem(taskFunc, TaskType.Parallel));ProcessQueue();}/// <summary>/// 立即执行 **并行任务**(有返回值)/// </summary>public Task<T> EnqueueParallelTask<T>(Func<Task<T>> taskFunc){var tcs = new TaskCompletionSource<T>();_taskQueue.Enqueue(new TaskItem(async () =>{try{T result = await taskFunc();tcs.SetResult(result);}catch (Exception ex){tcs.SetException(ex);}}, TaskType.Parallel));ProcessQueue();return tcs.Task;}/// <summary>/// 处理队列中的任务(支持顺序执行 & 并行执行)/// </summary>private async void ProcessQueue(){if (_isProcessing) return;_isProcessing = true;while (_taskQueue.TryDequeue(out var taskItem)){if (taskItem.Type == TaskType.Parallel){// 并行任务:立即执行,不等待_ = Task.Run(taskItem.TaskFunc);}else{// 顺序任务:等待执行await _semaphore.WaitAsync();try{await taskItem.TaskFunc();}catch (Exception ex){Console.WriteLine($"任务执行失败: {ex.Message}");}finally{_semaphore.Release();}}}_isProcessing = false;}
}

调用示例

using System;
using System.Threading.Tasks;class Program
{static async Task Main(){var queue = new AsyncTaskQueue();// **顺序执行任务**queue.EnqueueTask(async () =>{Console.WriteLine("顺序任务 1 开始...");await Task.Delay(2000);Console.WriteLine("顺序任务 1 结束");});queue.EnqueueTask(async () =>{Console.WriteLine("顺序任务 2 开始...");await Task.Delay(1000);Console.WriteLine("顺序任务 2 结束");});// **顺序执行任务(有返回值)**Task<int> task3 = queue.EnqueueTask(async () =>{Console.WriteLine("顺序任务 3(有返回值)开始...");await Task.Delay(1500);Console.WriteLine("顺序任务 3 结束");return 42;});// **并行任务**queue.EnqueueParallelTask(async () =>{Console.WriteLine("并行任务 A 开始...");await Task.Delay(3000);Console.WriteLine("并行任务 A 结束");});queue.EnqueueParallelTask(async () =>{Console.WriteLine("并行任务 B 开始...");await Task.Delay(2000);Console.WriteLine("并行任务 B 结束");});// **并行任务(有返回值)**Task<string> parallelTask = queue.EnqueueParallelTask(async () =>{Console.WriteLine("并行任务 C(有返回值)开始...");await Task.Delay(2500);Console.WriteLine("并行任务 C 结束");return "Hello, Parallel!";});// 等待顺序任务完成int result3 = await task3;Console.WriteLine($"顺序任务 3 返回值: {result3}");// 等待并行任务完成string parallelResult = await parallelTask;Console.WriteLine($"并行任务 C 返回值: {parallelResult}");// 等待所有任务完成await Task.Delay(5000);}
}
http://www.dtcms.com/wzjs/120690.html

相关文章:

  • 合肥网站推广 公司qq推广引流怎么做
  • 免费做微网站公司网站建设步骤
  • 住建部城乡建设网站自媒体平台注册官网下载
  • 装饰公司网站建设seo的优化技巧有哪些
  • 连云港网站 建设广州seo招聘
  • 登录建筑培训网优化网站标题是什么意思
  • 网站建设征求意见通知十大接单推广app平台
  • 浙江专业网页设计免费建站百度浏览器入口
  • 广州注册公司价格搜索排名优化软件
  • 网站建设请款报告论坛营销
  • 好用的网站开发软件抚顺网络推广
  • 汕头网站建设浩森宇特抖音推广渠道有哪些
  • 国外可以做推广的网站吗ciliba磁力搜索引擎
  • 武汉做网站制作百度seo点击
  • 成都网站建设千古互联三一crm手机客户端下载
  • 赣州网站建设长春seo按天计费
  • 钓鱼网站搭建教程推广联盟平台
  • 广州网站建设吧郑州seo优化顾问阿亮
  • 自己想建设一个网站南宁关键词排名公司
  • wordpress 远程设置长沙优化排名推广
  • 网站建设的过程包括几个阶段sem推广软件选哪家
  • 中石油工程建设公司网站长沙seo优化首选
  • 有没有专业做盐的网站成都企业网站seo技术
  • 黑龙江公司网站开发全渠道营销
  • 网站如何做信誉认证seo系统培训班
  • 做思维导图的网站百度云资源搜索引擎
  • 新华网站建设什么是seo站内优化
  • 德阳网站优化媒体发布公司
  • WordPress建站可以吗app开发公司哪家好
  • 企业网站的seo惠州网站建设方案推广