QQ登录

只需要一步,快速开始

APP扫码登录

只需要一步,快速开始

查看: 4377|回复: 0

[C#/.NET] C#多线程处理多个队列数据的方法

[复制链接]

等级头衔

积分成就    金币 : 2859
   泡泡 : 1516
   精华 : 6
   在线时间 : 1320 小时
   最后登录 : 2025-6-15

丰功伟绩

优秀达人突出贡献荣誉管理论坛元老活跃会员

联系方式
发表于 2021-10-14 10:03:34 | 显示全部楼层 |阅读模式
一、概述
, t2 a9 ~% `, B2 I( t8 w' @       多线程(multithreading),是指从软件或者硬件上实现多个线程并发执行的技术。具有多线程能力的计算机因有硬件支持而能够在同一时间执行多于一个线程,进而提升整体处理性能。具有这种能力的系统包括对称多处理机、多核心处理器以及芯片级多处理或同时多线程处理器。在一个程序中,这些独立运行的程序片段叫作“线程”(Thread),利用它编程的概念就叫作“多线程处理”。7 g1 B  c- @  D( F
       队列(Queue)代表了一个先进先出的对象集合。当您需要对各项进行先进先出的访问时,则使用队列。当您在列表中添加一项,称为入队,当您从列表中移除一项时,称为出队。
, G( T  `9 i) Q0 P; o9 q* U: i7 @) J       比如平常我们在处理定时任务的时候,假设就一台机器,我们不可能单线程一条一条数据的去跑,这时候就需要提高机器资源的利用率。下面我们来介绍下,如何实现多线程+队列以提高并发处理能力。
+ \1 q6 L8 a% h- C二、代码实现) S$ f, I1 T1 {
1、定义线程数threadNum和队列queues
% G9 Z* S- k  L7 {7 ]# \
/// <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、定义线程列表,往线程添加数据
+ Q0 X9 B7 v. Q) Y  M
   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++)
) S) c8 ?. z; |. e
   var taskList = Task.Factory.ContinueWhenAll(tasks.ToArray(), (ts) =>
            {
            });
            taskList.Wait();
4、从队列取出数据进行业务处理
  I, e+ v) J6 w$ c* k* y8 n, l
    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);
                }
            }
        }
运行测试:. t  b& {! c. U2 p
1.jpg
5 }8 i1 B4 r# c) P" Y9 E代码地址:https://gitee.com/conanOpenSource_admin/Example
您需要登录后才可以回帖 登录 | 立即注册

本版积分规则

QQ|手机版|小黑屋|paopaomj.COM ( 渝ICP备18007172号|渝公网安备50010502503914号 )

GMT+8, 2025-6-17 16:23

Powered by paopaomj X3.5 © 2016-2025 sitemap

快速回复 返回顶部 返回列表