android - Rxjava 与 kotlin 协程

Question

我需要从 rxkotlin 链启动协程，但我不确定这是对还是错，要从 rx 链启动协程，我使用 runblocking 启动挂起方法
示例

Single.just(someOperation())
   .map{
     someMethod(it)
   }
  .flatMap{
    startCoroutines(suspend { someOpeartions() } ) // i will be starting the coroutines here
  }

协程

fun startCoroutines(suspendingObj : suspend () -> Any){
  runBlocking(newFixedThreadPoolContext(1,"Thread")){
       suspendingObj.invoke()
  }
}

上面的代码是正确的做法还是有其他方法可以实现？谁能帮我解决这个问题

Answer 1

这个代码块从根本上是错误的。

1. 在您的情况下，确实没有必要使用协程，因为您可以使用 observeOn 在 flatMap 之前轻松更改 Rx 线程，并传递任何 Scheduler 你想要(比如 IO)。
2. Kotlin 协程旨在避免Threads，因为创建Threads 是一项非常昂贵的操作。并且您的函数 startCoroutines 为每个操作创建一个新线程，这没有任何意义并且可能会导致 溢出。您可以在这里阅读更多相关信息:Difference between a "coroutine" and a "thread"?
3. 在决定使用 runBlocking 之前，您应该始终尝试找到更好的系统设计。阻塞线程从来都不是一个好主意。