How to create custom Kotlin coroutine dispatcher worked on my ThreadPoolExecutor?

Question

In the process of migration to Kotlin, the question arose.
We already have some ThreadPools for different reasons.
How to execute coroutine on existed ThreadPool?

For exampe this code :

    suspend fun fetchMedia(): Flow<MediaItem> {
        return withContext(Dispatchers.IO) {...} 
    }

How to replace Dispatchers.IO to my own ThreadPoolExecutor ?

Answer 1

You can use Executor ThreadPools calling asCoroutineDispatcher() on it, like this:

suspend fun fetchMedia(): Flow<MediaItem> {
    return withContext(myThreadPool.asCoroutineDispatcher()) {...} 
}