답변 정말 감사합니다!

제가 이해가 잘 안되는 부분이 있어서 그런데, 혹시 해당 내용에 관해서 조금만 더 구체적으로 알려주실 수 있으실까요 ??

Dispatchers.Default 관련 추가 질문

1. [1번 항목에 대한 추가 질문입니다.] 아래의 코드가 실행이 되면, 여러 개의 코루틴이 동시에 실행이 될텐데 아주 만약에 먼저 실행된 코루틴이 limitedParallelism(8) 혹은 limitedParallelism(6)인 경우 모든 Default의 스레드를 다 사용하기 때문에 나머지 코루틴들은 실행가능한 Default 스레드가 없어서 먼저 시작된 코루틴이 종료되기까지 계속 기다려야 하는게 맞나요 ??
(코루틴들의 실행 순서보다는 스레드가 모두 사용되면 뒤의 코루틴들은 계속 기다려야 하는지가 궁금합니다.)

// CPU 코어가 4개인 컴퓨터
fun main() = runBlocking {
    launch(Dispatchers.Default.limitedParallelism(8)) {
        superCpuIntensiveTask()
    }
    
    launch(Dispatchers.Default) {
        lightCpuIntensiveTask()
    }

    launch(Dispatchers.Default.limitedParallelism(6)) {
        superCpuIntensiveTask2()
    }

    println("Done")
}

2. [2번 항목에 대한 추가 질문입니다.] 아래의 코드를 보면 여러번 limitedParallelism가 호출이 되는데, 아무리 많이 호출해도 Default 전체 스레드 중 일부로 제한이 된다는 것은 이해를 했습니다.
   
   그런데 제가 추가적으로 궁금한 점은 limitedParallelism(2)가 먼저 실행되는 경우 뒤에 오는 limitedParallelism(3)의 스레드 요청 수가 만족되지 못하고, limitedParallelism(3)가 먼저 실행이 되면 limitedParallelism(2)의 스레드 요청 수를 만족하지 못하는데
   이런 경우에 뒤에 실행되는 limitedParallelism는 해당 작업 코루틴이 실행되지 않고 대기를 하는 것인지, 남은 스레드 가지고 일단 실행을 하다가 추가적으로 스레드 할당이 되면 그때 스레드를 더 할당해서 동작을 하는 것인지 궁금합니다.

// CPU 코어가 4개인 컴퓨터
fun main() = runBlocking {
    launch(Dispatchers.Default.limitedParallelism(3)) {
        superCpuIntensiveTask()
    }
    
    launch(Dispatchers.Default.limitedParallelism(3)) {
        superCpuIntensiveTask2()
    }

    launch(Dispatchers.Default.limitedParallelism(2) {
        CpuIntensiveTask()
    }

    println("Done")
}

안녕하세요. 두 개 모두 같은 답변을 드릴 수 있을 것 같은데요.

Dispatchers.Default.limitedParallelism은 특정 작업을 위한 스레드를 제한하기 위한 것이고, 스레드를 배타적으로 사용하기 위한 함수가 아닙니다. 따라서 Dispatchers.Default가 8개의 스레드를 생성할 수 있다고 했을 때, Dispatchers.Default.limitedParallelism(8)이 호출된다고 하더라도 Dispatchers.Default를 사용하면 8개의 스레드를 여전히 사용할 수 있습니다. 마찬가지로 Dispatchers.Default.limitedParallelism(8)가 연속 두 번 호출되면 전체 스레드(8개) 를 사용하는 디스패처가 2개 생성되는 것일 뿐 입니다.

이것을 확인해보시기 위해서는 다음 코드를 실행해보시면 좋을 것 같습니다.

fun main() = runBlocking<Unit> {
    repeat(100) { repeat ->
        launch(Dispatchers.Default.limitedParallelism(8)) {
            repeat(100) {
                launch {
                    Thread.sleep(100L)
                    println("[${repeat}][${Thread.currentThread().name}] 코루틴 실행")
                }
            }
        }
    }
}

답변이 도움이 되셨으면 좋을 것 같습니다.

감사합니다.

코드를 동작시켜보니, 실행 순서에 상관없이 작업들이 분배되서 동작이 되네요.

[0][DefaultDispatcher-worker-8 @coroutine#5] 코루틴 실행
[0][DefaultDispatcher-worker-6 @coroutine#4] 코루틴 실행
[1][DefaultDispatcher-worker-10 @coroutine#10] 코루틴 실행
[0][DefaultDispatcher-worker-11 @coroutine#7] 코루틴 실행
[4][DefaultDispatcher-worker-9 @coroutine#15] 코루틴 실행
[2][DefaultDispatcher-worker-5 @coroutine#116] 코루틴 실행
[8][DefaultDispatcher-worker-15 @coroutine#331] 코루틴 실행
[9][DefaultDispatcher-worker-16 @coroutine#516] 코루틴 실행
[6][DefaultDispatcher-worker-13 @coroutine#117] 코루틴 실행
[4][DefaultDispatcher-worker-7 @coroutine#93] 코루틴 실행
[7][DefaultDispatcher-worker-14 @coroutine#220] 코루틴 실행
[5][DefaultDispatcher-worker-12 @coroutine#59] 코루틴 실행
[3][DefaultDispatcher-worker-4 @coroutine#25] 코루틴 실행
[1][DefaultDispatcher-worker-3 @coroutine#166] 코루틴 실행
[0][DefaultDispatcher-worker-1 @coroutine#41] 코루틴 실행
[10][DefaultDispatcher-worker-2 @coroutine#1109] 코루틴 실행
[4][DefaultDispatcher-worker-7 @coroutine#102] 코루틴 실행

limitedParallelism를 사용하면 사용할 스레드를 점유한다는 개념으로 이해를 해서 헷갈린 것 같습니다.

감사합니다!