C# 使用多線程如何傳遞兩個(gè)以上參數(shù)的實(shí)現(xiàn)方法(附示例)
某些情況下當(dāng)我們啟動(dòng)一個(gè)線程的時(shí)候會(huì)向該線程傳遞參數(shù)，有時(shí)除了功能上需要之外，我覺得還有就是為了我們能管理好啟動(dòng)的線程組（當(dāng)然，只開一兩個(gè)線程什么的也談不上不好管理了，我說的線程組是指10+的線程，我們很難去主動(dòng)控制的）。
因?yàn)閯偨佑|C#，所以還沒有在C#下用過多線程去實(shí)現(xiàn)某些功能。通過學(xué)習(xí)我發(fā)現(xiàn)單純的去啟動(dòng)線程很容易，反而是想要往線程中傳一些參數(shù)變得有點(diǎn)說道了，這里我想說傳入?yún)?shù)的數(shù)量為>=2。不過我們還是一步一步的來，帶大家過一遍C#下的多線程怎么搞。
以上一篇講的網(wǎng)絡(luò)通信的例子，把整個(gè)過程走一遍。這里網(wǎng)絡(luò)通信只是作為一個(gè)講解的示例，依舊是在控制臺(tái)（Console）程序下實(shí)現(xiàn)的。
當(dāng)Server端想要能與多個(gè)Client端進(jìn)行連通的話，就必須用到多線程機(jī)制，我的思路：當(dāng)程序啟動(dòng)后，Server端自己開一個(gè)專門用于進(jìn)行監(jiān)聽的線程，這樣主程序如果想做其他事也就不耽誤了。當(dāng)監(jiān)聽線程檢測(cè)到有連接的請(qǐng)求，就為這個(gè)IP單***建一個(gè)新的Socket（我們暫時(shí)稱為SA Socket）進(jìn)行通信用，當(dāng)然，這個(gè)SA通信的內(nèi)容（比如：收發(fā)消息）就是在一個(gè)新的線程或者兩個(gè)（我們暫時(shí)稱為TA線程）里實(shí)現(xiàn)的了，這個(gè)時(shí)候就需要我們往TA線程里傳入SA的專有ID，讓TA線程只專門為SA服務(wù)。之后的就依次類推了。
下面創(chuàng)建一個(gè)監(jiān)聽線程，這也是一個(gè)C#下最簡(jiǎn)單的多線程使用——創(chuàng)建多線程
- Thread ListenThread = new Thread(new ThreadStart(ServerListener));
- ListenThread.Start();
對(duì)，就是這么easy，Thread構(gòu)造函數(shù)里的參數(shù)類型為ThreadStart，這個(gè)東西官方解釋是一個(gè)委托（啊，這里就不講委托了，好像是C#特有的吧？反正我理解就是一個(gè)函數(shù)指針類型的東西或者是說某函數(shù)的別名，至于如何關(guān)聯(lián)方法與委托，就是用new 委托名(函數(shù)名)的方法），表示此線程開始執(zhí)行時(shí)要調(diào)用的方法。
關(guān)于委托大家可以下載http://down.51cto.com/data/1155877這個(gè)PPT，第229頁(yè)處有詳細(xì)講解，簡(jiǎn)單易懂。
如上所說，在監(jiān)聽線程里我會(huì)創(chuàng)建一個(gè)監(jiān)聽的socket，然后有連接的話，會(huì)返回一個(gè)新的Socket對(duì)象，看代碼：
- //用于連接通道的socket，我默認(rèn)創(chuàng)建了5個(gè)，也就是說與Server端最多只能連通5個(gè)socket
- Socket[] CommunicationSocket = new Socket[5];
- //index來維護(hù)所創(chuàng)建的socket數(shù)組
- int index = 0;
- …省略…
- //如有Client進(jìn)行連接，返回一個(gè)新的socket
- CommunicationSocket[index] = ListenSocket.Accept();
接下來就是本篇的關(guān)鍵部分了，由于我已經(jīng)創(chuàng)建好了一個(gè)用于通信的CommunicationSocket，所以現(xiàn)在需要去創(chuàng)建一個(gè)獨(dú)立的線程，用于專門為這個(gè)新的Socket作通信使用，而我傳入的參數(shù)就是CommunicationSocket這個(gè)對(duì)象以及這個(gè)對(duì)象在socket數(shù)組中的位置index。
既然new ThreadStart()只能傳入一個(gè)方法名，而沒有給我們傳參數(shù)的地方，那么針對(duì)于這個(gè)情況，我們需要用點(diǎn)小技巧，那就是使用類，看代碼：
- //消息操作類，用于傳入線程
- public class MessageHandler
- {
- Socket socket = null;
- int index = 0;
- bool StopFlag = false;
- public MessageHandler(Socket socket, int index)
- {
- this.socket = socket;
- this.index = index;
- Console.WriteLine("線程" + this.index + "號(hào)被創(chuàng)建！");
- }
- //接收線程調(diào)用的函數(shù)
- public void ReceiveMessage()
- {
- byte[] buffer = newbyte[1024*4];
- string message = null;
- try
- {
- while (!StopFlag)
- {
- int result = this.socket.Receive(buffer, 0, buffer.Length, SocketFlags.None);
- if (result < 0)
- {
- break;
- }
- message = System.Text.Encoding.UTF8.GetString(buffer);
- Console.Write("Client(" + DateTime.Now.ToShortTimeString() + "):" + message.Trim());
- Console.WriteLine();
- }
- }
- catch (System.Exception ex)
- {
- Console.WriteLine(ex.ToString());this.socket.Close();
- }
- }
- //發(fā)送線程調(diào)用的函數(shù)
- public void SendMessage()
- {
- byte[] buffer = newbyte[1024 * 4];
- string message = null;
- try
- {
- while (!StopFlag)
- {
- message = Console.ReadLine();
- if (message.ToLower().Equals("byebye"))
- {
- StopFlag = true;
- }
- buffer = System.Text.Encoding.UTF8.GetBytes(message);
- this.socket.Send(buffer);
- }
- }
- catch (System.Exception ex)
- {
- Console.WriteLine(ex.ToString());this.socket.Close();
- }
- }
- }
這是我自己定義的消息操作類，大家看看，這個(gè)類的里面即實(shí)現(xiàn)了利用socket發(fā)送消息，也實(shí)現(xiàn)了接收消息的方法。寫到這大家有沒有來點(diǎn)靈感呢？再繼續(xù)往下看：
- //如果出現(xiàn)新的socket通道，那么分別創(chuàng)建一個(gè)該通道的接收線程與發(fā)送線程
- //創(chuàng)建 MessageHandler類的對(duì)象，同時(shí)將參數(shù)傳入到該對(duì)象中去，該實(shí)例的方法用于作為線程的目標(biāo)方法
- MessageHandler MsgHandler = new MessageHandler(CommunicationSocket[index], index);
- ReceiveThread[index] = new Thread(new ThreadStart(MsgHandler.ReceiveMessage));
- ReceiveThread[index].Start();
- SendThread[index] = new Thread(new ThreadStart(MsgHandler.SendMessage));
- SendThread[index].Start();
- index++;
這樣就實(shí)現(xiàn)了往線程里傳遞1個(gè)以上的參數(shù)了。
這里主要就是展示一下如何去傳多個(gè)參數(shù)，對(duì)于多線程的管理等細(xì)節(jié)上還是有很多漏洞的，所以大家挑干的來就好了。
另外我附上原碼，跟文章中的有點(diǎn)出路，主要是在文章中我對(duì)一些變量名稱稍加進(jìn)行了修改，便于大家看代碼。
***要說的是在C#多線程中傳遞一個(gè)參數(shù)的時(shí)候，有另外的專門方法，記得也是跟委托有關(guān)，不過具體我只是當(dāng)時(shí)看了一下，這會(huì)兒已經(jīng)記不得了，感興趣的朋友可以去搜一下，不過話說回來，既然都會(huì)傳多個(gè)參數(shù)了，傳一個(gè)參數(shù)的話應(yīng)該也很好搞定的。
希望能幫到有需要的人。
