C# 多线程处理List数据的示例代码

2023-07-08 08:33:04 73

代码思路

将要处理的数据放到ConcurrentQueue中，然后开启多个线程去处理数据，处理完成后，再到队列中获取下一个待处理数据。

ConcurrentQueue表示线程安全的先进先出(FIFO)集合，属于System.Collections.Concurrent命名空间下的一个数据结构

直接上代码

///

///多线程处理数据（无返回值） ///

///数据类型 ///待处理数据 ///数据处理方法（有参数无返回值） ///处理线程数量 ///是否等待执行结束 staticvoidRunTask(Listlist,Actionaction,intthreadCount=5,boolwaitFlag=true) { ConcurrentQueuequeue=newConcurrentQueue(list); Task[]tasks=newTask[threadCount]; for(inti=0;i { while(queue.TryDequeue(outTt)) { action(t); } }); } if(waitFlag) { Task.WaitAll(tasks); } }

///

///多线程处理数据（返回处理后列表） ///

///数据类型 ///待处理数据 ///数据处理方法（有参数有返回值） ///处理线程数量 ///数据处理后结果 staticListRunTask(Listlist,Funcfunc,intthreadCount=5) { varresult=newList(); ConcurrentQueuequeue=newConcurrentQueue(list); Task>[]tasks=newTask>[threadCount]; for(inti=0;i>(()=> { varrList=newList(); while(queue.TryDequeue(outTt)) { rList.Add(func(t)); } returnrList; }); } Task.WaitAll(tasks); for(inti=0;i

调用方法

Listlist=newList(){1,2,3,4,5,6,7,8,9};
//输出列表中的数据，且加上“action”字符前缀
RunTask(list,d=>{Console.WriteLine("action"+d);});

//对列表中数据都执行“*2”的操作
varresult=RunTask(list,d=>{returnd*2;});
result.ForEach(d=>Console.WriteLine(d));

最后的话

上面的代码只是简单的实现了对数据的处理，并没有考虑到对内存的使用限制，一般的项目中使用还是可以的。
最后我尝试了下，生成一个100M的列表，然后将其加载到ConcurrentQueue，监控程序内存占用，发现没有很大的内存占用变化。

以上就是C#多线程处理List数据的示例代码的详细内容，更多关于c#处理list数据的资料请关注毛票票其它相关文章！

声明：本文内容来源于网络，版权归原作者所有，内容由互联网用户自发贡献自行上传，本网站不拥有所有权，未作人工编辑处理，也不承担相关法律责任。如果您发现有涉嫌版权的内容，欢迎发送邮件至：czq8825#qq.com（发邮件时，请将#更换为@）进行举报，并提供相关证据，一经查实，本站将立刻删除涉嫌侵权内容。

C# 多线程处理List数据的示例代码

代码思路

调用方法

最后的话

热门推荐

随机推荐