这篇文章主要介绍如何使用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);
}
}
}运行测试
以上是“如何使用C#多线程处理多个队列数据”这篇文章的所有内容，感谢各位的阅读！希望分享的内容对大家有帮助，更多相关知识，欢迎关注亿速云行业资讯频道！
亿速云「云服务器」，即开即用、新一代英特尔至强铂金CPU、三副本存储NVMe SSD云盘，价格低至29元/月。点击查看>>
免责声明：本站发布的内容（图片、视频和文字）以原创、转载和分享为主，文章观点不代表本网站立场，如果涉及侵权请联系站长邮箱：is@yisu.com进行举报，并提供相关证据，一经查实，将立刻删除涉嫌侵权内容。
