인프런 커뮤니티 질문&답변

강사님 강의를 듣고 배치 단위로 요청을 가져와 Redis 서버에서 작업을 처리하는 부분에 코루틴을 적용하려고 합니다. 강의를 통해 최소한의 스레드로 여러 코루틴을 실행해야 코루틴을 극대화할 수 있다고 이해했습니다. n개의 요청은 모두 독립적이며 배치 단위로 가져온 이유는 1개의 스레드로 여러 코루틴을 실행하기 위함입니다.

Redis는 마스터에서만 작업이 가능하므로 요청을 보내고, 응답받아 후속 처리하는 부분을 

• Redis 서버로 요청 (코루틴1)

• Redis 서버로부터 응답받아 후속 처리 (코루틴2)

로 분리했습니다.

1개의 스레드에서 여러 코루틴을 동작시키기 위해 이런 기준으로 코루틴의 중단 지점을 생성하는 것이 적절한지 궁금합니다.

또한 n개의 요청을 모두 Redis 서버로 보낸 후 응답 받는 것이 아니라

응답을 받고 후속 처리가 가능한 요청은 ‘모든 요청을 Redis 서버로 전달했다는 여부와 상관없이’ 후속처리를 하기 위해 다음과 같이 코드를 작성했습니다.

coroutineScope {
   val jobs = userIds.map { userId ->
       async {
           // main 스레드가 처리
           val result = 레디스 접근 메서드 (RedisTemplate)
           Pair(userId, result)
       }
   }
   jobs.forEach { job ->
       launch(Dispatchers.IO) {
           val (userId, status) = job.await()
           // 응답에 대한 후속 처리
            // 결과마다 다른 DefaultDispatcher-worker 가 처리
       }
   }
}

위와 같이 작성하면 Redis로 요청을 보내는 부분은 1개의 main스레드가 처리하지만, 후속 처리는 결과마다 다른 DefaultDispatcher-workder가 처리합니다. 이는 결과마다 다른 스레드가 처리하는 것이 맞다면 이 코드는 코루틴을 제대로 사용하지 못하고 있다고 생각하는데 제 생각이 맞는지 궁금합니다.

coroutineScope {
   launch {
       for(userId in userIds) {
           val result = 레디스 접근 메서드
           channel.send(Pair(userId, result))
       }
       channel.close()
   }
   launch {
       for(result in channel) {
           // 응답에 대한 후속 처리
       }
   }
}

위와 같이 작성하면 1개의 main 스레드가 모든 작업을 처리합니다. 이렇게 작성해야 코루틴을 제대로 사용하는 것이 맞는지 궁금합니다.

강의 잘 들었고 감사합니다!