甚至在不同的线程中调用/调用

本文关键字：调用 线程 | 更新日期: 2023-09-27 18:30:10

我必须用C#制作一个Instant Messenger服务器。服务器是ConsoleApplication项目。我想制作一个在3个线程中运行的服务器。我将在下面的代码中进行解释。

问题是，我如何从一个单独的线程调用一个函数，或者在一个单独线程上生成一个事件？

这是主服务器类。

public class GiNetServer
{
     public void Start()
     {
         netServer  = new NetServer();
         msgHandler = new NetMsgHandler();
         netServer.NewNetMsg += msgHandler.HandleMsg;
         Work();
     }
     private void Work()
     {
         while(true)  //This runs in the MainThread
           sleep(1);
     }
}

NetServer类创建两个线程：acceptClientThread和receiveMessagesThread。接收线程调用NewNetMsg。

public class NetServer
{
     public event NewNetMsgEventHandler NewNetMsg;
     public NetServer()
     {
          acceptClientsThread = new Thread(ListenForClients);
          receiveMessageThread = new Thread(Receive);
          //and of course starts them here...
     }
     private void Receive()
     {
          while(true)
          {
               Heartbeat();
          }
     }
     private void Heartbeat()
     {
          foreach(netClient in clientsList)
          {
               if (netClient.DataAvalible)
               {
                   netClient.Recive();
               }
               if (!netClient.IsBufferEmpty())
               {
                   nextMsg = netClient.NextMessage();
                   if (nextMsg != null)
                       NewNetMsg(netClient, nextMsg);  //Call the event!
               }
          }
     }
}

如何使msgHandler.HandleMsg函数在单独的线程或MainThread中运行？

像这样，HandleMsg在receiveMessagesThread中运行。

上面的代码是伪代码。如果有什么不清楚的地方，请告诉我。

甚至在不同的线程中调用/调用

根据您的需求，有很多不同的方法可以将HandleMsg调用转移到不同的线程上。最简单的方法是使用ThreadPool:在不同的线程上引发NewNetMsg事件

ThreadPool.QueueUserWorkItem(s => NewNetMsg(netClient, nextMsg));

您也可以使用任务并行库（TPL）。您还可以将事件添加到由专用后台线程处理的ConcurrentQueue中。还有更多的选择。如果没有更多的细节，就不可能给出更具体的建议。

相关文章：