Zi 字媒體
2017-07-25T20:27:27+00:00
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)
寫了
5860316篇文章，獲得
23313次喜歡