如何限制CoroutineWorker同时运行数量？配置后仍并行执行的问题

我创建了一个测试用的CoroutineWorker：

class Work(context: Context, workerParameters: WorkerParameters) :
    CoroutineWorker(context, workerParameters) {
    override suspend fun doWork(): Result {
        Log.d("bagins", "Work ${this.tags.first()} started")
        runBlocking {
            delay(5000)
        }
        Log.d("bagins", "Work ${this.tags.first()} finished")
        return Result.success()
    }
}

通过workManager.enqueue(workers)批量启动Worker，想要限制最多2个任务同时执行。按照示例修改了AndroidManifest.xml移除默认初始化：

<provider
    android:name="androidx.startup.InitializationProvider"
    android:authorities="${applicationId}.androidx-startup"
    tools:node="remove">
</provider>

并自定义Application配置WorkManager：

class App : Application(), Configuration.Provider {
    override fun getWorkManagerConfiguration(): Configuration {
        val executor = Executors.newFixedThreadPool(2)
        return Configuration.Builder().setExecutor(executor).build()
    }

    override fun onCreate() {
        super.onCreate()
        WorkManager.initialize(this, workManagerConfiguration)
    }
}

但执行10次workManager.enqueue后，所有Worker仍同时运行，需要实现始终最多2个并行执行的效果。

核心原因 #

你设置的setExecutor是给普通Worker类（非协程Worker）用的线程池，CoroutineWorker的调度不依赖这个线程池，它会使用自身默认的CoroutineDispatcher，所以你的并行限制不生效。

正确实现方式 #

要限制CoroutineWorker的并行数，需要自定义指定并行度的CoroutineDispatcher，并通过setCoroutineDispatcher配置到WorkManager中：

1. 修改Application的WorkManager配置：

class App : Application(), Configuration.Provider {
    override fun getWorkManagerConfiguration(): Configuration {
        // 创建并行度为2的CoroutineDispatcher
        val limitedDispatcher = Executors.newFixedThreadPool(2).asCoroutineDispatcher()
        return Configuration.Builder()
            .setCoroutineDispatcher(limitedDispatcher)
            .build()
    }

    override fun onCreate() {
        super.onCreate()
        WorkManager.initialize(this, workManagerConfiguration)
    }
}

2. 优化Worker代码（避免runBlocking阻塞协程线程）：

class Work(context: Context, workerParameters: WorkerParameters) :
    CoroutineWorker(context, workerParameters) {
    override suspend fun doWork(): Result {
        Log.d("bagins", "Work ${this.tags.first()} started")
        // 直接使用suspend函数delay，无需runBlocking
        delay(5000)
        Log.d("bagins", "Work ${this.tags.first()} finished")
        return Result.success()
    }
}

额外说明 #

• 该方式适用于WorkManager 2.6及以上版本，setCoroutineDispatcher是官方为CoroutineWorker提供的专属调度配置项。
• 确保Manifest中已移除默认的InitializationProvider，避免WorkManager被默认初始化覆盖你的自定义配置。

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