TIL

7강 CoroutineScope와 CoroutineContext

• 이미 이전 강의에서 CoroutineScope를 활용한 적 있다.

fun main(): Unit = runBlocking {
  val job1 = CoroutineScope(Dispatchers.Default).launch {
    delay(1_000L)
    printWithThread("Job 1")
  }
}

• launch와 async는 사실 CoroutineScope의 확장함수이다.
• 지금까지 runBlocking이 코루틴과 루틴 세계를 이어주며 CoroutineScope를 제공해준 것이다.
  • 직접 CoroutineScope를 만들면 runBlocking은 필요하지 않다.

fun main() {
  val job = CoroutineScope(Dispatchers.Default).launch {
    delay(1_000L)
    printWithThread("Job 1")
  }
  
  Thread.sleep(1_500L) // job이 새 스레드에서 루트 코루틴으로 실행되기에 기다려야 Job1이 출력될 것이다.
}

CoroutineScope와 CoroutineContext 주요 역할

• CoroutineScope는 코루틴이 탄생할 수 있는 영역이다.
  • CoroutineScope는 CoroutineContext 데이터 보관한다.
• CoroutineContext는 코루틴과 관련된 데이터를 보관
  • CoroutineExceptionHandler, 코루틴 이름, 코루틴 그 자체, CoroutineDispatcher 등
  • Dispatcher는 코루틴이 어떤 스레드에 배정될지 관리한다.

public interface CoroutineScope {
  public val coroutineContext: CoroutineContext
}

코루틴의 Structured Concurrency 기반

• Structured Concurrency의 기반이 되는 원리는 다음과 같다.

1. 부모 코루틴이 최초 CoroutineScope에서 생성된다.
2. 자식 코루틴이 생성되면 같은 영역에서 생성되고 부모의 context에서 필요한 정보를 덮어 써 새로운 자신의 context를 만든다.
   1. 이 과정에서 부모-자식 관계도 설정한다.

클래스 내부에서 독립적인 CoroutineScope를 관리

• 한 영역에 있는 코루틴들은 영역 자체를 취소시킴으로써 모든 코루틴을 종료시킬 수도 있다.

class AsyncLogic {
  private val scope = CoroutineScope(Dispatchers.Default)
  
  fun doSomething() {
    scope.launch {
      // 어떤 작업을 수행
    }
  }
  
  fun destroy() {
    scope.cancel()
  } 
}

val asyncLogic = AsyncLogic()
asyncLogic.doSomething()

asyncLogic.destory() // 필요 없어지면 모두 정리

CoroutineContext

• Map + Set을 합쳐놓은 상태
  • Element(key-value)로 데이터를 저장
  • 같은 key의 데이터는 유일
• + 기호를 이용해 Element들을 합칠 수도 있다.

fun main() {
  // 각각이 Element이다.
  CoroutineName("나만의 코루틴") + Dispatchers.Default
  
  // context 자체에 Element를 추가할 수도 있다.
  coroutineContext + CoroutineName("나만의 코루틴")
  
  // Element를 제거할 수도 있다.
  coroutineContext.minusKey(CoroutineName.key)
}

CoroutineDispatcher

• 코루틴을 스레드에 배정하는 역할을 수행한다.
• Dispatchers.Default
  • 가장 기본적인 디스패처
  • CPU 자원을 많이 쓸 때 권장
  • 별다른 설정이 없으면 사용된다.
• Dispatchers.IO
  • I/O 작업에 최적화
• Dispatchers.Main
  • 보통 UI 컴포넌트를 조작하기 위한 디스패처
  • 특정 의존성을 갖고 있어야 정상적으로 활용 가능
• 자바 스레드풀인 ExecutorService를 디스패처로 변환
  • asCoroutineDispatcher 확장 함수 사용

fun main() {
  val threadPool = Executors.newSingleThreadExecutor()
  CoroutineScope(threadPool.asCoroutineDispatcher()).launch {
    printwithThread("새로운 코루틴")
  }
}