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