如何计算在 Kotlin 中创建的线程数？

Question

我有套接字编程，我正在为每个客户端创建新线程并使用具有多线程的应用程序，如下所示。

fun ClientHandler() {
        try {
            var count = 0
            var serverSocket = ServerSocket(5000)

            while (true) {
                val socket: Socket = serverSocket!!.accept()
                count++
                socket.reuseAddress = true
                _log("${socket.remoteSocketAddress} Client Connected. Connected client count is $count")
                Thread(ServerThread(socket)).start() //Here i'm creating Threads. 
            }
        } catch (e: ConnectException) {
            _logEx("UnExpected connection error", e)
        } catch (ex: IOException) {
            _logEx("ClientHandler", ex)
        } catch (e: Exception) {
            _logEx("ServerSocketHandler ", e)
        }

}

internal inner class ServerThread(socket: Socket) : Runnable  {
    private val client: Socket = socket
    private val reader: Scanner = Scanner(client.getInputStream())
    private val writer = PrintStream(client.getOutputStream())
    private var receiveString: String = ""
    override fun run() {
        try {
            while(reader.hasNextLine()){
                receiveString = reader.nextLine() ?: ""
                _log("Message received: " + receiveString)
                if (receiveString != null && receiveString != "") {
                    checkMessage(receiveString, writer,client)
                }
            }
        } catch (ex: Exception) {
            _log("Cannot read the message. Please try again")
            //_log(ex.localizedMessage)
            val spReq = Error()
            spReq.sendErrorMsg(writer, "Cannot read the message. Please try again",client)
        }
    }
}

更新 我也添加了 ServerThread 代码部分。

如何关注他们并获得他们的状态？

Answer 1

您可以通过 Map 来跟踪线程及其状态以供进一步参考

fun ClientHandler() {
    try {
        var count = 0
        val serverSocket = ServerSocket(5000)

        while (true) {
            val socket: Socket = serverSocket.accept()
            count++
            socket.reuseAddress = true
            threads["thread name here"] = ServerThread(socket)
        }
    } catch (e: ConnectException) {
        e.printStackTrace()
    } catch (e: IOException) {
        e.printStackTrace()
    } catch (e: Exception) {
        e.printStackTrace()
    }
}

fun stopServerThread(threadName: String) {
    threads[threadName]?.interrupt()
}

internal inner class ServerThread(private val client: Socket) : Thread()  {
    private val reader = Scanner(client.getInputStream())
    private val writer = PrintStream(client.getOutputStream())
    private var receiveString: String = ""
    
    init {
        start()
    }
    
    override fun run() {
        try {
            while(reader.hasNextLine()){
                if (isInterrupted) {
                    break
                }
                receiveString = reader.nextLine() ?: ""
                if (receiveString != "") {
                    checkMessage(receiveString, writer, client)
                }
            }
        } catch (ex: Exception) {
            _log("Cannot read the message. Please try again")
            //_log(ex.localizedMessage)
            val spReq = Error()
            spReq.sendErrorMsg(writer, "Cannot read the message. Please try again",client)
        }
    }
}