c# 多线程处理多个数据的方法
作者:conan 时间:2023-12-01 17:45:58
目录
概述
代码实现
代码地址
概述
多线程(multithreading),是指从软件或者硬件上实现多个线程并发执行的技术。具有多线程能力的计算机因有硬件支持而能够在同一时间执行多于一个线程,进而提升整体处理性能。具有这种能力的系统包括对称多处理机、多核心处理器以及芯片级多处理或同时多线程处理器。在一个程序中,这些独立运行的程序片段叫作“线程”(Thread),利用它编程的概念就叫作“多线程处理”。
队列(Queue)代表了一个先进先出的对象集合。当您需要对各项进行先进先出的访问时,则使用队列。当您在列表中添加一项,称为入队,当您从列表中移除一项时,称为出队。
比如平常我们在处理定时任务的时候,假设就一台机器,我们不可能单线程一条一条数据的去跑,这时候就需要提高机器资源的利用率。
下面我们来介绍下,如何实现多线程+队列以提高并发处理能力。
代码实现
1、定义线程数threadNum和队列queues
/// <summary>
/// 线程总数
/// </summary>
private int threadNum = 4;
/// <summary>
/// 总数
/// </summary>
private int totalCount = 0;
/// <summary>
/// 已处理
/// </summary>
private int index = 0;
/// <summary>
/// 队列
/// </summary>
private ConcurrentQueue<AssetRepayment> queues = new ConcurrentQueue<AssetRepayment>();
2、定义线程列表,往线程添加数据
public void SubDeTransaction()
{
var list = new List<AssetRepayment>();
for (int i = 0; i < 1000; i++)
{
list.Add(new AssetRepayment() { Title = i.ToString() + "---" + Guid.NewGuid().ToString() });
}
if (list == null || list.Count() == 0)
{
Console.WriteLine("没有可执行的数据");
return;
}
totalCount = list.Count;
Console.WriteLine("可执行的数据:" + list.Count() + "条");
foreach (var item in list)
{
queues.Enqueue(item);
}
List<Task> tasks = new List<Task>();
for (int i = 0; i < threadNum; i++)
{
var task = Task.Run(() =>
{
Process();
});
tasks.Add(task);
}
var taskList = Task.Factory.ContinueWhenAll(tasks.ToArray(), (ts) =>
{
});
taskList.Wait();
}
3、对线程数进行限制 for (int i = 0; i < threadNum; i++)
var taskList = Task.Factory.ContinueWhenAll(tasks.ToArray(), (ts) =>
{
});
taskList.Wait();
4、从队列取出数据进行业务处理
private void Process()
{
while (true)
{
var currentIndex = Interlocked.Increment(ref index);
AssetRepayment repayId = null;
var isExit = queues.TryDequeue(out repayId);
if (!isExit)
{
break;
}
try
{
Console.WriteLine(repayId.Title);
Console.WriteLine(string.Format(" 共{0}条 当前第{1}条", totalCount, currentIndex));
}
catch (Exception ex)
{
Console.WriteLine(ex);
}
}
}
代码地址
https://gitee.com/conanOpenSource_admin/Example
来源:https://mp.weixin.qq.com/s/iPi3wL2-00vYUJ57X0FSiw
标签:c#,多线程
![](/images/zang.png)
![](/images/jiucuo.png)
猜你喜欢
android 修改launcher行数和列数的方法
2021-10-02 14:19:37
![](https://img.aspxhome.com/file/2023/1/139351_0s.png)
Spring使用@Autowired为抽象父类注入依赖代码实例
2023-02-01 09:30:35
Java基础-Java的体系结构
2022-05-18 00:19:05
![](https://img.aspxhome.com/file/2023/1/63501_0s.png)
解析C#中的常量及如何在C#编程中定义常量
2022-03-20 22:58:36
手把手教你SpringBoot轻松整合Minio
2022-07-24 14:00:37
关于springboot中对sqlSessionFactoryBean的自定义
2022-12-09 06:05:09
详解Spring Security如何配置JSON登录
2023-02-08 17:39:07
![](https://img.aspxhome.com/file/2023/3/72353_0s.png)
Java中&和&&的区别简单介绍
2023-02-23 12:12:23
C#属性(Attribute)用法实例解析
2021-09-20 16:01:29
Android自定义View实现分段选择按钮的实现代码
2022-09-06 07:46:21
![](https://img.aspxhome.com/file/2023/9/137839_0s.gif)
C#中字符串的一般性和特殊性
2023-03-23 19:06:07
![](https://img.aspxhome.com/file/2023/8/126058_0s.png)
详解Android四种存储方式
2022-06-26 21:51:35
实例解析使用Java实现基本的音频播放器的编写要点
2023-11-29 14:54:26
C#中dynamic关键字的正确用法(推荐)
2023-11-12 09:20:22
java如何使用自己的maven本地仓库详解
2022-08-01 12:13:44
C#使用System.Net.Mail类实现邮件发送
2022-04-26 01:38:21
maven如何打包动态环境变量(包括启动脚本)
2023-07-16 03:48:56
Android自定义View之圆形进度条式按钮
2023-09-07 22:51:28
![](https://img.aspxhome.com/file/2023/7/138127_0s.png)
详解Java中的流程控制
2022-03-29 06:52:19
Spring Boot Security 结合 JWT 实现无状态的分布式API接口
2021-06-04 05:01:17