如何在UI线程中断后台线程中NetworkStream的Read()阻塞调用？

直接使用Thread.Abort()是绝对不推荐的——它会强制终止线程，引发不可预测的资源泄漏、线程状态混乱，属于严重不安全的做法。推荐采用以下两种可控的方式实现中断：

方法1：关闭NetworkStream或底层Socket #

当UI线程需要中断后台读取时，直接调用networkStream.Close()或socket.Close()（如果持有底层Socket的引用）。此时阻塞在Read()的后台线程会立刻抛出IOException，你可以在后台线程的异常捕获块中处理这个信号，优雅终止线程。

代码示例：

// UI线程触发中断逻辑
private void TriggerReadStop()
{
    // _networkStream为后台线程使用的NetworkStream实例
    _networkStream?.Close();
}

// 后台线程的读取循环
private void BackgroundReadTask()
{
    byte[] buffer = new byte[1024];
    try
    {
        while (true)
        {
            int readBytes = _networkStream.Read(buffer, 0, buffer.Length);
            // 处理读取到的数据
        }
    }
    catch (IOException ex)
    {
        // 捕获流关闭异常，线程安全退出
        Console.WriteLine("读取操作被中断：" + ex.Message);
    }
}

方法2：调用Socket的Shutdown方法 #

如果持有底层Socket对象，可调用socket.Shutdown(SocketShutdown.Receive)。这会让NetworkStream.Read()立即返回0字节（表示流已结束），后台线程检测到返回值为0后，可主动退出循环，无需捕获异常。

代码示例：

// UI线程触发中断逻辑
private void TriggerReadStop()
{
    // _socket为底层Socket实例
    _socket.Shutdown(SocketShutdown.Receive);
}

// 后台线程的读取循环
private void BackgroundReadTask()
{
    byte[] buffer = new byte[1024];
    using (NetworkStream stream = new NetworkStream(_socket))
    {
        int readBytes;
        while ((readBytes = stream.Read(buffer, 0, buffer.Length)) > 0)
        {
            // 处理读取到的数据
        }
        // Read返回0，说明流已关闭，线程退出
        Console.WriteLine("读取流终止，线程正常退出");
    }
}

关键注意事项 #

• 禁止使用Thread.Abort()：它会破坏线程的正常执行流程，导致NetworkStream、Socket等资源无法正确释放，甚至引发应用程序崩溃。
• 保证线程安全：操作NetworkStream或Socket时，要确保UI线程和后台线程的访问互斥，比如通过锁控制，避免重复关闭等冲突操作。

内容的提问来源于stack exchange，提问作者Zach