C# 使用多线程如何传递两个以上参数的实现方法(附示例)-阿里云开发者社区

某些情况下当我们启动一个线程的时候会向该线程传递参数，有时除了功能上需要之外，我觉得还有就是为了我们能管理好启动的线程组（当然，只开一两个线程什么的也谈不上不好管理了，我说的线程组是指10+的线程，我们很难去主动控制的）。

因为刚接触C#，所以还没有在C#下用过多线程去实现某些功能。通过学习我发现单纯的去启动线程很容易，反而是想要往线程中传一些参数变得有点说道了，这里我想说传入参数的数量为>=2。不过我们还是一步一步的来，带大家过一遍C#下的多线程怎么搞。

以上一篇讲的网络通信的例子，把整个过程走一遍。这里网络通信只是作为一个讲解的示例，依旧是在控制台（Console）程序下实现的。

当Server端想要能与多个Client端进行连通的话，就必须用到多线程机制，我的思路：当程序启动后，Server端自己开一个专门用于进行监听的线程，这样主程序如果想做其他事也就不耽误了。当监听线程检测到有连接的请求，就为这个IP单独创建一个新的Socket（我们暂时称为SA Socket）进行通信用，当然，这个SA通信的内容（比如：收发消息）就是在一个新的线程或者两个（我们暂时称为TA线程）里实现的了，这个时候就需要我们往TA线程里传入SA的专有ID，让TA线程只专门为SA服务。之后的就依次类推了。

下面创建一个监听线程，这也是一个C#下最简单的多线程使用——创建多线程

Thread ListenThread = new Thread(new ThreadStart(ServerListener));
ListenThread.Start();

对，就是这么easy，Thread构造函数里的参数类型为ThreadStart，这个东西官方解释是一个委托（啊，这里就不讲委托了，好像是C#特有的吧？反正我理解就是一个函数指针类型的东西或者是说某函数的别名，至于如何关联方法与委托，就是用new 委托名(函数名)的方法），表示此线程开始执行时要调用的方法。

关于委托大家可以下载http://down.51cto.com/data/1155877这个PPT，第229页处有详细讲解，简单易懂。

如上所说，在监听线程里我会创建一个监听的socket，然后有连接的话，会返回一个新的Socket对象，看代码：

//用于连接通道的socket，我默认创建了5个，也就是说与Server端最多只能连通5个socket

Socket[] CommunicationSocket = new Socket[5];
//index来维护所创建的socket数组

int index = 0;
…省略…
//如有Client进行连接，返回一个新的socket
CommunicationSocket[index] = ListenSocket.Accept();

接下来就是本篇的关键部分了，由于我已经创建好了一个用于通信的CommunicationSocket，所以现在需要去创建一个独立的线程，用于专门为这个新的Socket作通信使用，而我传入的参数就是CommunicationSocket这个对象以及这个对象在socket数组中的位置index。

既然new ThreadStart()只能传入一个方法名，而没有给我们传参数的地方，那么针对于这个情况，我们需要用点小技巧，那就是使用类，看代码：

//消息操作类，用于传入线程

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 + "号被创建！");

     }

     //接收线程调用的函数

     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();

          }

    }

    //发送线程调用的函数

    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();

         }

    }
}

这是我自己定义的消息操作类，大家看看，这个类的里面即实现了利用socket发送消息，也实现了接收消息的方法。写到这大家有没有来点灵感呢？再继续往下看：

//如果出现新的socket通道，那么分别创建一个该通道的接收线程与发送线程
//创建 MessageHandler类的对象，同时将参数传入到该对象中去，该实例的方法用于作为线程的目标方法

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++;