如何将函数调用限制到特定的线程/执行器

我目前正在为移动应用程序设计数据库。最近我发现在后台访问数据库非常有用的功能:

private val IO_EXECUTOR = Executors.newSingleThreadExecutor()

fun ioThread(f : () -> Unit) {
    IO_EXECUTOR.execute(f)
}

此外,我发现不需要同步代码,因为数据库只在一个线程(即 SingleThreadExecutor )。

唯一的问题是,必须限制以下方法只能通过 ioThread 功能(或使用 IO_EXECUTOR )。

abstract class MyDatabase : RoomDatabase() {
    companion object {
        fun init(context: Context) { ... }
        fun getInstance() { ... }
    }

有没有可能在 Kotlin / Java 是吗?

更新: 目前我有这个实现,但我认为应该有更好的实现

// App.kt file
private val IO_EXECUTOR = Executors.newSingleThreadExecutor()
private var IO_THREAD_ID: Long = -1L

private fun getIOThreadId(): Long {
    if (IO_THREAD_ID == -1L)
        IO_THREAD_ID = IO_EXECUTOR.submit(Callable<Long> { Thread.currentThread().id }).get()

    return IO_THREAD_ID
}

fun notInIOThread() = Thread.currentThread().id != getIOThreadId()

fun ioThread(f : () -> Unit) {
    IO_EXECUTOR.execute(f)
}

然后使用 notInIOThread() 在里面 init() 和 getInstance() 功能