C# 多執行序 簡易範例(CS_Console_Wait_Multithread) – jashliao部落格

C# 多執行序 簡易範例(CS_Console_Wait_Multithread)

GITHUB: https://github.com/jash-git/CS_Console_Wait_Multithread

01.建立一個 監聽/等待的所有其他執行序 工作完成的執行序: public static void Thread_MT_M(object arg=null)

02.實際工作的子執行序(負責把傳過來的數字相加): Thread_MT_C(object arg=null)

using System;
using System.Collections;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading;

namespace CS_Console_Wait_Multithread
{
    class Program
    {
        public static ArrayList[] ALCInupt;
        public static ArrayList[] ALCOutput;
        public static Thread[] th_C;
        public static int intAns;
        public static void Thread_MT_M(object arg=null)
        {
            int i = 0;
            int threadCount = 0;
            int threadAmount = 27;//執行序總量
            //---
            //ArrayList 物件陣列初始化
            ALCInupt = new ArrayList[threadAmount];
            ALCOutput = new ArrayList[threadAmount];
            th_C = new Thread[threadAmount];
            
            for (i=0;i< threadAmount; i++)
            {
                ALCInupt[i] = new ArrayList();
                ALCOutput[i] = new ArrayList();           
            }
            //---ArrayList 物件陣列初始化

            //---
            //把輸入資料放入對應變數中
            for (i = 0; i < threadAmount; i++)
            {
                int k = (i + 1) * 10;
                for (int j = 0; j < 10; j++)
                {
                    ALCInupt[i].Add((k - j) + "");
                }
            }
            //---把輸入資料放入對應變數中

            //---
            //依序兩兩建立子執行序，並等待執行完畢
            do
            {
                th_C[threadCount] = new Thread(Thread_MT_C);
                th_C[threadCount].Start(threadCount);

                threadCount++;

                if(threadCount< threadAmount)
                {
                    th_C[threadCount] = new Thread(Thread_MT_C);
                    th_C[threadCount].Start(threadCount);
                }

                bool blncheck = false;
                do
                {
                    Thread.Sleep(100);
                    blncheck = false;
                    if ((threadCount - 1)< threadAmount)
                    {
                        blncheck |= th_C[(threadCount - 1)].IsAlive;
                    }
                    if (threadCount < threadAmount)
                    {
                        blncheck |= th_C[threadCount].IsAlive;
                    }
                } while (blncheck);

                
                if (threadCount < threadAmount)
                {
                    string[] buf01 = ALCOutput[threadCount][(ALCOutput[threadCount].Count - 1)].ToString().Split(';');
                    intAns += Convert.ToInt32(buf01[1]);
                }
                if ((threadCount - 1) < threadAmount)
                {
                    string[] buf02 = ALCOutput[(threadCount - 1)][(ALCOutput[(threadCount - 1)].Count - 1)].ToString().Split(';');
                    intAns += Convert.ToInt32(buf02[1]);
                }
                Console.WriteLine("{0} threads finish...", (threadCount+1));

                threadCount++;
            } while (threadCount < threadAmount);
            //---依序兩兩建立子執行序，並等待執行完畢
        }
        public static void Thread_MT_C(object arg=null)
        {
            int index = Convert.ToInt32(arg);
            int sum, data;
            sum = 0;
            for(int i=0;i< ALCInupt[index].Count;i++)
            {
                data = Convert.ToInt32(ALCInupt[index][i].ToString());
                sum += data;
                ALCOutput[index].Add(data + ";" + sum);
                Thread.Sleep(10);
            }
        }
        public static void Pause()
        {
            Console.Write("Press any key to continue...");
            Console.ReadKey(true);
        }
        public static void Wait()
        {
            Console.Clear();
            Console.Write("Wait: ");
            Thread.Sleep(500);

            Console.Clear();
            Console.Write("Wait: \\");
            Thread.Sleep(500);

            Console.Clear();
            Console.Write("Wait: |");
            Thread.Sleep(500);

            Console.Clear();
            Console.Write("Wait: /");
            Thread.Sleep(500);
            Console.Clear();
        }
        static void Main(string[] args)
        {
            intAns = 0;
            Thread th_M = new Thread(Thread_MT_M);
            th_M.Start();
            do
            {
                Wait();
            }while (th_M.IsAlive);
            Console.Clear();
            Console.WriteLine("1+2+3+...+270={0}", intAns);

            Pause();
        }
    }
}

PS

判斷執行序是否還在執行
執行序傳遞參數
執行序共享全域變數
物件陣列建立與實體化(ArrayList)