c# 多线程处理多个数据的方法
作者:conan 发布时间:2023-12-01 17:45:58
标签:c#,多线程
目录
概述
代码实现
代码地址
概述
多线程(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
0
投稿
猜你喜欢
- 一、Java把这些不同来源和目标的数据都统一抽象为数据流。Java语言的输入输出功能是十分强大而灵活的。在Java类库中,IO部分的内容是很
- Spring 基于注解启动主要有两个Class实现注解启动AnnotationConfigApplicationContextAnnotat
- Java中的static关键字可以用于修饰变量、方法、代码块和类,还可以与import关键字联合使用,使用的方式不同赋予了static关键字
- 本文实例为大家分享了PhotoView实现图片双击放大单击退出的具体代码,供大家参考,具体内容如下实现思路1.复制PhotoView&nbs
- idea乱码修改bin目录下的idea.exe.vmoptions无效今天在学习Activiti工作流的时候,发现创建bpmn文件总是出现中
- cookie和session的区别和联系cookie是本地客户端用来存储少量数据信息的,保存在客户端,用户能够很容易的获取,安全性不高,存储
- 本文实例讲述了Spring与Struts整合之让Spring管理控制器操作。分享给大家供大家参考,具体如下:一 Web配置<?xml
- * 与过滤器在讲Spring boot之前,我们先了解一下过滤器和 * 。这两者在功能方面很类似,但是在具体技术实现方面,差距还是比较大的
- 本文所述为C#实现根据指定容器和控件名字获得控件的方法,在进行C#应用程序设计时有一定的借鉴价值。分享给大家供大家参考借鉴。具体实现方法如下
- 一.前言这一篇来看看 SpringIOC 里面的一个细节点 , 来简单看看 BeanDefinition 这个对象 , 以及有没有办法对其进
- 最近由于工作原因,没时间更新,开始吧~~关于json的返回需要用到一个工具包来将书转换为json格式,在此用到的jar包为: im
- 平时在开发时经常会用到 const,readonly,static 关键字,可以肯定这些关键词是完全不同的概念,但有时候他们在用法上很相似以
- 标题index界面加载问题刚开始学习springBoot记录一下遇到的小问题1.index.html加载不出来的问题我习惯性的将index.
- 1.使用response对象提供的sendRedirect()方法可以将网页重定向到另一个页面。重定向操作支持将地址重定向到不同的主机上,这
- 容器适配器我们可以看出,栈中没有空间配置器(内存池),而是适配器适配器是一种设计模式(设计模式是一套被反复使用的、多数人知晓的、经过分类编目
- groovy是一种动态脚本语言,适用于一些可变、和规则配置性的需求,目前Spring提供ScriptSource接口,支持两种类型,一种是R
- 使用的是idea+restful风格第一:引入依赖为:<!--poi--> <dependenc
- 一、结论先行ArrayList在JDK1.8与JDK1.7底层区别JDK1.7:ArrayList像饿汉式,直接创建一个初始容量为10的数组
- SpringMVC RESTFul访问首页实现一、新建 index.html在 webapp\WEB-INF\templates 下新建首页
- 用Android studio做一个简易计算器,供大家参考,具体内容如下长话短说,先建立一个Android项目;创建完成后打开activit