在单独的线程中开始接收

Question

出于某种原因，我需要在单独的线程上执行 BeginReceive，就像这个例子：

    public void WaitForData()
    {
        Thread t = new Thread(WaitForDataThread);
        t.Start();
    }

    public void WaitForDataThread()
    {
        try
        {
            CSocketPacket theSocPkt = new CSocketPacket();
            theSocPkt.thisSocket = m_socClient;
            m_asynResult = m_socClient.BeginReceive(theSocPkt.dataBuffer, 0, theSocPkt.dataBuffer.Length, SocketFlags.None, OnDataReceived, theSocPkt);
        }
        catch (SocketException se)
        {
            MessageBox.Show(se.Message);
        }
    }

但我总是在 BeginReceive 调用后立即收到错误，OnDataReceived 立即引发，在这种情况下它将调用 EndReceive 方法，并且总是抛出此错误：“I/O 操作已中止，因为线程退出或应用程序请求”。

但是如果我删除了分离线程部分（比如直接调用 WaitForDataThread()，而不通过 WaitForData() 方法），一切正常。

如果您想知道为什么我需要创建一个单独的线程，那是因为我需要在事件期间调用 BeginReceive，该事件将由来自不同类的不同线程生成。这与创建一个像上面的示例一样的新线程几乎相同，我需要让它工作。

有没有办法可以做到这一点？

Answer 1

在msdn（Socket.EndReceive 的文档）上找到了答案：

由给定线程发起的所有 I/O 都是 该线程退出时取消。一个 挂起的异步操作可以 如果线程在 操作完成。

您必须确保在您完成套接字 I/O 之前，您启动套接字操作的线程不会退出。

一种解决方法是使用线程池线程，如here 所述。

Answer 2

我假设您的主线程不会等到数据到来，而是在生成另一个线程后简单地退出。完成主线程会杀死整个应用程序，因此您的 WaitForData 线程也会死亡。

您必须执行以下操作：

1. 启动 WaitForData 线程
2. 在主线程中做任何你想做的事
3. 等到 WaitForData 线程在主线程中完成 (Thread.Join?)
4. 然后退出。