Kotlin单例Connection初始化遇Thread.join()阻塞问题求助

我正在用Kotlin开发一款Android客户端应用，作为团队服务端的配套客户端。我创建了一个Connection单例对象来存储与服务端Socket连接的所有必要数据：

object Connection {
    const val HOST = "host_name" // 项目中已正确定义
    const val PORT = 52137
    const val TIMEOUT = 5000
    val socket: Socket = Socket()
    /* ... */
    val connectData = MutableLiveData<String>()
    val errorData = MutableLiveData<String>()

    init {
        val connect = Thread({
            val address = InetSocketAddress(HOST, PORT)
            socket.connect(address, TIMEOUT)
        })
        connect.uncaughtExceptionHandler = Thread.UncaughtExceptionHandler({ t, e ->
            e.printStackTrace()
        })
        connect.start()
        connect.join() /* 这里想确保Socket完全初始化 */
        /* 一些额外的数据处理 */
    }
    /* 一些函数 */
}

我用join()来保证Socket完全初始化，但在LoginActivity中访问该对象时，初始化过程卡在了connect.join()处。LoginActivity代码如下：

class LoginActivity: AppCompatActivity() {
    override fun onCreate(savedInstanceState: Bundle?) {
        super.onCreate(savedInstanceState)
        setContentView(R.layout.activity_login)

        Connection.connectData.observe(this, Observer(this::displayConnectData))
        Connection.errorData.observe(this, Observer(this::displayError))

        val viewModel = ViewModelProviders.of(this).get(LoginViewModel::class.java)
        login_button.setOnClickListener({
            val loggedIn = viewModel.login(username.text.toString(), password.text.toString())
            if (loggedIn) {
                val intent = Intent(this, MainMenuActivity::class.java)
                startActivity(intent)
                finish()
            }
        })
    }

    private fun displayConnectData(message: String?) {
        Toast.makeText(this, message, Toast.LENGTH_SHORT).show()
    }

    private fun displayError(message: String?) {
        Toast.makeText(this, message, Toast.LENGTH_SHORT).show()
    }
}

我知道Kotlin的对象是懒初始化的，Connection对象会在调用Connection.connectData.observe时开始初始化，但即使设置了connect超时，仍卡在join()。请问能否简单修复该问题，或是需要更换实现方案？

问题根源 #

你遇到的核心问题是：单例的init代码块运行在主线程中，而connect.join()会阻塞当前线程（也就是主线程），直到连接线程执行完毕。Android主线程被阻塞超过几秒就会触发ANR（应用无响应），而且在阻塞期间，LiveData的观察回调根本无法执行，界面也会完全卡死。

哪怕你设置了Socket超时，join()还是会让主线程一直等到连接线程结束——不管是成功还是失败，这段时间主线程都没法处理UI事件，自然看起来像是“卡住了”。

简单修复方案 #

直接去掉connect.join()，让连接线程在后台独立运行，同时在连接成功/失败时通过LiveData通知UI层：

object Connection {
    const val HOST = "host_name"
    const val PORT = 52137
    const val TIMEOUT = 5000
    val socket: Socket = Socket()
    val connectData = MutableLiveData<String>()
    val errorData = MutableLiveData<String>()

    init {
        val connect = Thread({
            try {
                val address = InetSocketAddress(HOST, PORT)
                socket.connect(address, TIMEOUT)
                // 连接成功后通知UI
                connectData.postValue("连接成功！")
                // 这里执行你的额外数据处理逻辑
            } catch (e: IOException) {
                // 捕获连接异常，通知UI
                errorData.postValue("连接失败：${e.message}")
                e.printStackTrace()
            }
        })
        connect.start()
        // 移除connect.join()，不要阻塞主线程
    }

    /* 其他函数 */
}

为什么这能解决问题？ #

1. 去掉join()后，单例的init代码块会快速执行完毕，主线程不会被阻塞，LoginActivity能正常完成初始化，LiveData的观察也能正常注册。
2. 连接逻辑在后台线程独立执行，成功或失败的结果通过postValue()（确保在主线程更新LiveData）通知UI，不会影响主线程的正常运行。

额外优化建议 #

• 不要直接在单例中持有Socket对象并在init中初始化，最好提供一个connect()方法，让UI层（比如LoginViewModel）在合适的时机主动触发连接，而不是在单例首次被访问时自动执行。
• 考虑用Coroutines替代原生Thread，Kotlin协程处理异步逻辑更简洁，也更容易管理生命周期（比如在Activity销毁时取消连接任务）。
• 确保Socket操作的异常都被妥善捕获并通过errorData通知用户，而不是只打印堆栈信息。

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