异步socket服务器长操作任务

Question

我的问题可能很荒谬，但我在网上找不到任何信息。我的服务器不断读取从连接到它的客户端发送的数据，根据收到的数据，我执行某些操作。我的问题是，如果我的操作时间很长，我是否需要创建一个新线程以便 BeginRecieve 不会被阻塞？如果没有，我需要做什么？代码：private void ReceiveCallback(IAsyncResult ar){    try    {        Socket current = (Socket)ar.AsyncState;        int received;        try        {            received = current.EndReceive(ar);        }        catch        {            return;        }        byte[] recBuf = new byte[received];        Array.Copy(buffer, recBuf, received);        var st = Helper.ByteToObject(recBuf);        if ((st is string s))        {            if (s == "Something")            {                //Long operating task, do i need to use a new thread?            }        }        current.BeginReceive(buffer, 0, BUFFER_SIZE, SocketFlags.None, ReceiveCallback, current);    }    catch    {        return;    }}

Answer 1

处理长时间运行的任务的最佳方法是拥有一个线程，您可以启动并提交任务信息。这将允许您的主线程继续从客户端接收数据，而另一个线程继续处理您需要做的实际工作。

我通常实现的方法是为每个独特的任务定义一个函数，它接受必要的输入，在需要时由主任务启动。然后我保留一个向量来保存所有线程句柄，以便我们可以跟踪线程。

您将需要一种方法来同步由线程操作的任务的结果，这最终可能会产生竞争条件，因此您需要添加互斥锁以防止出现问题。您可能还想创建一个处理队列，该队列由客户端发送的消息填充，因为您不希望以数千个线程结束。

我通常设置一个线程限制，等于运行它的系统上的硬件线程，当我需要线程时，我只启动那么多。队列将允许未处理的数据等待线程完成其任务并变为可用。

有很多方法可以做到这一点，并没有真正正确的答案