如何无需等待客户端响应即可停止ClientsHandler线程

问题的核心是input.readObject()是阻塞IO操作，即便runFlag被设为false，线程仍会卡在这个方法上等待客户端输入，无法立即退出循环。要实现立即停止线程，需要结合线程中断机制或主动关闭Socket打破阻塞，同时优化状态标志的线程安全性。

具体修改方案 #

1. 替换静态runFlag为线程安全的实例变量 #

静态runFlag会导致所有客户端线程共享同一个状态，一个客户端断开会影响其他线程。改用AtomicBoolean保证线程安全，且每个实例独立维护自己的运行状态。

2. 在close()方法中主动关闭Socket+中断线程 #

关闭Socket会直接中断阻塞的readObject()操作，使其抛出IOException；同时中断线程，双重保障线程能立即跳出阻塞逻辑。

3. 优化资源关闭逻辑 #

使用Kotlin的use语法（等效于try-with-resources）自动关闭流和Socket，避免手动关闭可能出现的异常遗漏。

修改后的代码：

class ClientsHandler(
    private val socket: Socket,
    private val commandManager: CommandManager
) : Runnable {
    private val isRunning = AtomicBoolean(true)
    private lateinit var currentThread: Thread

    override fun run() {
        currentThread = Thread.currentThread()
        // use语法自动关闭Socket、输入输出流
        socket.use { sock ->
            ObjectInputStream(sock.getInputStream()).use { input ->
                ObjectOutputStream(sock.getOutputStream()).use { output ->
                    val username = (input.readObject() as User).username
                    println("$username connected")

                    while (isRunning.get()) {
                        try {
                            val request = input.readObject() as ServerRequest
                            output.writeObject(ServerCommandInvoker.invoke(request, commandManager))
                            // 检查线程中断状态，及时退出循环
                            if (Thread.interrupted()) break
                        } catch (e: IOException) {
                            println("$username disconnected (socket closed/interrupted)")
                            break
                        } catch (e: Exception) {
                            println("$username disconnected due to error: ${e.message}")
                            break
                        }
                    }
                }
            }
        }
        println("$username handler thread stopped")
    }

    fun close() {
        isRunning.set(false)
        // 中断线程，唤醒阻塞的IO操作
        if (::currentThread.isInitialized) currentThread.interrupt()
        // 主动关闭Socket，强制终止阻塞的read操作
        try {
            socket.close()
        } catch (e: IOException) {
            // 忽略关闭异常
        }
    }
}

关键改进点说明 #

• 线程安全的状态管理：AtomicBoolean保证多线程环境下状态修改的原子性，避免静态变量的全局干扰。
• 双重终止保障：既通过线程中断唤醒阻塞逻辑，又主动关闭Socket强制终止IO操作，确保线程立即退出。
• 自动资源回收：use语法自动处理流和Socket的关闭，避免资源泄漏。
• 中断状态检查：在每次请求处理后检查线程中断状态，确保即使无IO异常也能及时退出循环。

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