Android 4.1协程问题：阻塞队列导致后续launch无法执行

这个问题我之前在维护旧版本Android项目时碰到过，核心原因是旧系统上协程调度器的线程池实现差异，咱们一步步拆解：

问题原因 #

本质是Android 4.1（API 16）上Coroutines默认调度器Dispatchers.Default的线程池是单线程模式，导致阻塞操作占满线程后，后续协程无法执行：

• 当你用无参数的launch启动协程时（如果是GlobalScope的launch或者未指定调度器的Scope），默认会使用Dispatchers.Default。在Android 4.1中，这个调度器底层的线程池默认只有1个核心线程。
• 第二个协程执行ArrayBlockingQueue.take()时，这是一个无限阻塞的调用（直到队列有元素），会完全占用这个唯一的线程，后续的第三个协程任务没有可用线程来调度，因此一直处于等待状态。
• 而Android 6.0+等更高版本中，Dispatchers.Default使用的是多线程池（核心线程数等于设备CPU核心数），即使一个线程被阻塞，其他协程可以分配到空闲线程执行，所以不会出现任务卡住的情况。

另外你提到的两种恢复场景也能验证这个逻辑：

• 换成thread执行阻塞操作时，阻塞在独立线程，不会占用协程调度器的线程池，后续协程自然正常运行。
• 向队列添加元素解除阻塞后，被占用的线程会执行完第二个协程，线程回到空闲状态，第三个协程就能得到执行机会。

解决方案 #

针对这个问题，有两种简单可靠的解决方式：

1. 显式将阻塞操作放到Dispatchers.IO

Dispatchers.IO是Coroutines专门为阻塞IO操作设计的调度器，它的线程池会根据阻塞情况动态扩容，完全不会因为单个阻塞任务影响其他协程：

class MainActivity : AppCompatActivity() {
    private val blockingQueue = ArrayBlockingQueue<String>(10)
    override fun onCreate(savedInstanceState: Bundle?) {
        super.onCreate(savedInstanceState)
        launch {
            Log.d(javaClass.simpleName, "TEST 1")
        }
        // 显式指定Dispatchers.IO处理阻塞逻辑
        launch(Dispatchers.IO) {
            blockingQueue.take().run {
                Log.d(javaClass.simpleName, "TEST 2 $this")
            }
        }
        launch {
            Log.d(javaClass.simpleName, "TEST 3")
        }
    }
}

2. 自定义多线程调度器（适用于特殊场景）

如果需要更精细的线程控制，可以自定义一个固定大小的多线程调度器，确保有足够的线程处理任务：

// 自定义一个包含3个线程的调度器，可根据需求调整大小
private val customDispatcher = Executors.newFixedThreadPool(3).asCoroutineDispatcher()

class MainActivity : AppCompatActivity() {
    private val blockingQueue = ArrayBlockingQueue<String>(10)
    override fun onCreate(savedInstanceState: Bundle?) {
        super.onCreate(savedInstanceState)
        launch(customDispatcher) {
            Log.d(javaClass.simpleName, "TEST 1")
        }
        launch(customDispatcher) {
            blockingQueue.take().run {
                Log.d(javaClass.simpleName, "TEST 2 $this")
            }
        }
        launch(customDispatcher) {
            Log.d(javaClass.simpleName, "TEST 3")
        }
    }

    override fun onDestroy() {
        super.onDestroy()
        // 务必关闭自定义调度器，避免内存泄漏
        customDispatcher.close()
    }
}

额外提醒

绝对不要在Dispatchers.Main（主线程）中执行阻塞操作，这不仅会卡住协程，还会造成UI卡顿、ANR等严重问题，所有阻塞逻辑都应该放到后台调度器中执行。

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