强制挂起的函数在一个线程上工作以在后台映射 Realm 对象

Question

假设我定期（每 3 秒）需要读取一些RealmObjects的列表，并且我想将这些对象映射到将用于填充列表内容的简单数据对象。

对于那些想知道的人来说，有以下三个原因：

• ViewHolder在我的情况下，计算s 中的视图的值和行为（可见性，即）非常复杂
• 我想使用ListAdapterwhich 需要提供DiffUtilCallback哪些将在除 UI 之外的其他线程上执行，因此在其方法中进行所需的计算是不可能的，因为它们将在未创建它们的线程中使用。
• 从 Realm 中移除视图层的依赖

我不能简单地以基本方式使用协程从一个可用线程跳转到另一个，因为我将（并且我确实）最终收到“领域已经关闭”异常。

我想出的唯一解决方案是使用仅使用一个线程的调度程序，newSingleThreadContext("RealmSingleThreadContext")例如：

class RealmSingleThreadContext {
    val ctx = NewSingleThreadedContext("RealmSingleThreadContext")

    lateinit var realm : Realm

    init {
        // opening Realm connection for thread "RealmSingleThreadContext"
        GlobalScope.launch(ctx) { realm = Realm.getDefaultInstance() }
    }

    fun close() {
        GlobalScope.launch(ctx) { if (!realm.isClosed()) realm.close() }
    }


}

这个类通过 Dagger 作为单例提供，最终在最后，我将有一个线程在后台为整个应用程序做映射，我的“主”视图模型将调用这个类的onClosed方法close()方法。

这是我如何使用它：

class HomeViewModel @Inject constructor(/* other */var realmSingleThreadContext: RealmSingleThreadContext) {

    var topLiveEventsUI: MutableLiveData<List<EventPreviewUI>> = MutableLiveData(listOf())

    fun useRealmInBckg() {
       viewModeScope.launch(realmSingleThreadContext.ctx) {
           topLiveEventsUI.postValue(eventsReadUseCase.getTopLiveEvents()
               .map{ mapper.map(it) }
        }
    }

}

唯一的问题是该函数newSingleThreadContext(name: String)有@ObsoleteCoroutineApi注释，所以这意味着它很快就会被删除。

我的问题是：除了使用这个过时的 Dispatcher 之外，有人可以提出另一种解决方案吗？

Answer 1

从 Java 执行程序制作自己的单线程调度程序非常容易：

val singleThreadContext = Executors.newSingleThreadExecutor().asCoroutineDispatcher()