[原创][3]探究C#多线程开发细节-“用ConcurrentQueue＜T＞解决多线程的无顺序性的问题“

本文介绍: 经过上一篇文章([原创][2]探究C#多线程开发细节-“线程的无顺序性“-CSDN博客), 得知在不干预的情况下, 默认运行是无顺序的. 那么这样特性, 对程序的运行来说, 是好还是坏呢？其实无顺序没有好坏之说, 只跟程序功能的业务需求有关系. 当一个业务需求也可以说是功能, 需要多线程的无顺序特性, 那么在写代码的过程中就不要干预它. 如果业务需求对顺序有严格要求, 那么在编写多线程时, 就要适当得干预了.

[简介]
常用网名: 猪头三
出生日期: 1981.XX.XX
QQ: 643439947
个人网站: 80x86汇编小站 https://www.x86a sm.org
编程生涯: 2001年~至今[共22年]
职业生涯: 20年
开发语言: C/C++、80x86ASM、PHP、Pe rl、Obje c t i v e-C、Object Pa s cal、C#、Pyt h on
开发工具: Visu al Stud io、Del p hi、XCode、Eclip s e、C++ Builde r
技能种类: 逆向驱动磁盘文件
 研发领域: Win dows 应用软件安全/Windows 系统内核安全/Windows 系统磁盘数据安全/macOS应用软件安全
 项目经历: 磁盘性能优化/文件系统数据恢复/文件信息采集/敏感文件监测跟踪/网络安全检测

[序言]
经过上一篇文章([原创][2]探究C#多线程开发细节-“线程的无顺序性“-CSDN博客), 得知在不干预的情况下, 默认运行是无顺序的. 那么这样特性, 对程序的运行来说, 是好还是坏呢？其实无顺序没有好坏之说, 只跟程序功能的业务需求有关系. 当一个业务需求也可以说是功能, 需要多线程的无顺序特性, 那么在写代码的过程中就不要干预它. 如果业务需求对顺序有严格要求, 那么在编写多线程时, 就要适当得干预了.

[到底什么需求和场合需要控制多线程的运行顺序呢?]
这里举例一个最常见的场合: 比如有一个10G的文件, 程序创建了10个线程来读取内容, 每个线程分别依次读取1G内容(0号线程读取的范围是0~1G, 1号线程读取的范围1~2G, 2号线程读取的范围是2~3G, 依次类推), 然后每个线程读取内容完毕之后, 就在程序界面上显示.

[上面的场合, 如果不控制多线程的运行顺序时, 会发生什么现象呢?]
出现的现象就是: 假设当1号线程最先读取完1~2G范围的内容, 该线程就马上在界面显示. 当显示完成之后, 0号线程才完成读取0~1G范围的内容并在界面显示. 这样内容就错乱了.

这里把刚才抽象的描述实例化: 假设一个文件有10个字, “我爱CSDN编程网站“. 每1个线程分别控制1个字的读取和显示, 形成如下关系:

0号线程读取并显示 “我”
1号线程读取并显示 “爱”
2号线程读取并显示 “C”
3号线程读取并显示 “S”
4号线程读取并显示 “D”
5号线程读取并显示 “N”
6号线程读取并显示 “编”
7号线程读取并显示 “成”
8号线程读取并显示 “网”
9号线程读取并显示 “站”

   public partial class Form_Main : Form
   {

       private ConcurrentQueue<int> mpr_cq_ThreadIndex = new ConcurrentQueue<int>();


       public class Thread_Run
       {
           public int mpu_int_ThreadIndex;
           private Action<int> mpr_action_UpdateWaiteInfo;
           private ConcurrentQueue<int> mpr_cq_ThreadIndex;

           public Thread_Run(Action<int> action_param_UpdateWaiteInfo, ref ConcurrentQueue<int> cq_param_ThreadIndex)
           {
               mpr_action_UpdateWaiteInfo = action_param_UpdateWaiteInfo;
               mpr_cq_ThreadIndex = cq_param_ThreadIndex;
           }

           public int mpu_fun_ShowIndex()
           {
               return mpu_int_ThreadIndex;
           }

           public void mpu_pro_StartThread()
           {
               
               Thread class_Thread = new Thread(Thread_Exe);
               class_Thread.Start();
           }

           private void Thread_Exe()
           {
               int int_Dq_ThreadIndex;

               // 核心重点: N号线程等待N-1线程是否完成任务
               while (true)
               {
                   if (mpr_cq_ThreadIndex.TryPeek(out int_Dq_ThreadIndex) &amp;&amp; int_Dq_ThreadIndex == mpu_int_ThreadIndex)
                   {
                       //调用委托方法来更新UI
                       mpr_action_UpdateWaiteInfo?.Invoke(mpu_int_ThreadIndex);

                       mpr_cq_ThreadIndex.TryDequeue(out _);

                       break;
                   
                   }

                   Thread.Sleep(5);
               }
           }
       }// End Thread_Run()


       public Form_Main()
       {
           InitializeComponent();
       }


       public void mpu_pro_UpdateWaiteInfo(int int_param_ThreadIndex)
       {

           if (InvokeRequired)
           {
               this.Invoke((MethodInvoker)delegate {

                   lb_WaitInfo.Text += (Environment.NewLine + string.Format("{0} 号线程已经跑到终点.", int_param_ThreadIndex));

               });
           }
       }


       private void Bn_StartThread_Click(object sender, EventArgs e)
       {

           // 启动10个线程
           for (int int_Index = 0; int_Index < 10; int_Index++)
           {

               mpr_cq_ThreadIndex.Enqueue(int_Index);

               Thread_Run class_ThreadRun = new Thread_Run(mpu_pro_UpdateWaiteInfo, ref mpr_cq_ThreadIndex);
               class_ThreadRun.mpu_int_ThreadIndex = int_Index;
               class_ThreadRun.mpu_pro_StartThread();
               
           }

       }

   }