반응형 Develop/Reactor+Coroutine7 [Coroutine] 코루틴 스코프 함수 코루틴 스터디를 하며 정리중인 시리즈 글왜 코루틴을 써야할까?[Coroutine] 코루틴 빌더, 코루틴 컨텍스트[Coroutine] 구조화된 동시성[Coroutine] 코루틴 스코프 함수 🎉 coroutineScope 코루틴 스코프 함수는 중단함수 내에서 스코프가 필요할 때 사용한다. coroutineScope는 코루틴 스코프 함수의 일종이다. 🔸 coroutineScope 로 인해 중단되는 코루틴coroutineScope는 새로운 코루틴을 생성하면 작업이 끝날 때까지 coroutineScope를 호출한 코루틴을 중단시킨다. 아래 예제를 보면 println이 순차적으로 진행되는 것을 볼 수 있다.suspend fun main(): Unit = runBlocking { launch { printl.. 2024. 6. 29. [Coroutine] 구조화된 동시성, 코루틴 스코프 코루틴 스터디를 하며 정리중인 시리즈 글왜 코루틴을 써야할까?[Coroutine] 코루틴 빌더, 코루틴 컨텍스트[Coroutine] 구조화된 동시성, 코루틴 스코프[Coroutine] 코루틴 스코프 함수 🎄 구조화된 동시성'왜 코루틴을 써야할까?'에서 구조화된 동시성에 대해 아주 잠깐 설명했었다. 이 포스팅을 통해서 좀 더 자세한 이야기를 다뤄보려고 한다. 구조화된 동시성(Structured Concurrency)이란, 비동기 작업을 구조화함으로써 비동기 프로그래밍을 보다 안정적이고 예측 가능하게 만드는 원칙이다. 코틀린 코루틴은 비동기 작업인 코루틴을 부모-자식 관계로 구조화함으로써 코루틴을 안전하게 관리 및 제어하게 만들어졌다. 구조화된 코루틴의 특징을 하나하나 알아보자. 🌱 부모 코루틴의 실행.. 2024. 6. 29. [Coroutine] 코루틴 빌더, 코루틴 컨텍스트 코루틴 스터디를 하며 정리중인 시리즈 글왜 코루틴을 써야할까?[Coroutine] 코루틴 빌더, 코루틴 컨텍스트[Coroutine] 구조화된 동시성[Coroutine] 코루틴 스코프 함수 🔅 코루틴 빌더 코틀린 코루틴은 코루틴을 일시 중단시킨다. 이런 방식을 통해 스레드를 블로킹할 때보다 훨씬 가볍게 사용할 수 있다. 그런데 이 코루틴 중단은 중단 함수 내에서만 일어날 수 있다. 그리고 중단함수는 중단함수 내에서만 호출되어야 한다. 중단함수가 최초로 시작되는 지점은 어디일까? 바로 코루틴 빌더다. 🔸 코루틴 빌더중단 함수가 시작되는 지점모든 코루틴 빌더는 자신의 Job을 생성 (Job에 대한 설명은 하단에 있다.)launch, async, runBlocking 등이 있다. 🔸 launch별개의 코루.. 2024. 6. 23. 왜 코루틴을 써야할까? 코루틴 스터디를 하며 정리중인 시리즈 글왜 코루틴을 써야할까?[Coroutine] 코루틴 빌더, 코루틴 컨텍스트[Coroutine] 구조화된 동시성[Coroutine] 코루틴 스코프 함수😏 스레드의 한계 JVM은 스레드를 기반으로 동작한다. 단일 스레드는 동시 작업을 수행할 수 없기 때문에 하나의 작업이 오래 걸리면 다른 작업의 처리도 지연된다. 이를 극복하기 위해 등장한 것이 멀티 스레드다. 멀티 스레드는 스레드를 여러 개 사용해 작업을 처리하는 것으로, 병렬 처리가 가능해진다. (동시성과 병렬성의 차이는 동시성 (Concurrency) vs 병렬성 (Parallelism) 글을 참고하길 바란다.) 멀티 스레드 이미지를 보면 메인 스레드가 Thread-0, Thread-1에 요청을 보내 작업을 분.. 2024. 6. 9. [Reactor] 서버 느리게 만드는 API 개발하기 (feat: block) 1. 엉망진창 시작 🤯 Reactor에 대해서 'WebFlux는 비동기 프로그래밍할 때 쓴다', 'Mono는 단일 요소, Flux는 여러 요소' 이 두 가지 외에는 아무것도 모르는 상태에서 로직을 작성해야 했다. WebFlux의 기본 문법을 공부하는 중이긴 했지만, 학습 속도보다 업무 진행이 훨씬 급했다. 무작정 코드를 작성하니 어떻게든 내가 원하는 결과가 만들어졌다. 베타 서버 데이터를 이용한 테스트도 완료했다. 성공 케이스, 실패 케이스, 에러 케이스 모두 예상한대로 돌아갔다. 며칠 뒤, 퇴근했다가 갑자기 베타 서버가 이상하다는 슬랙이 온다.😭 2. 문제의 코드 😵 자세한 비즈니스 로직을 생략하기 위해 조금 억지스러운 예제를 가져왔다. 상품을 조회할 때, 상품을 판매하는 판매사명이 "test".. 2024. 5. 6. [Spring] ReactiveCrudRepository를 이용한 삭제 시 주의점 😟 문제 상황 찜을 삭제하고 별도의 작업을 위해 event publish 하는 로직을 작성하였다.fun remove(favorite: Favorite): Mono = favoriteRepository.deleteById(favorite.id) .flatMap { productService.findById(favorite.productId) } // event publish할 때 필요한 데이터 조회 .flatMap { product -> val favoriteRequest = toFavoriteEventRequest(favorite, product) Mono.fromCallable { favoriteEventPublisher.publ.. 2024. 4. 28. [Reactor] zip vs zipWith vs zipWhen 💡 zip() 여러개의 Publisher를 인자로 넘기고, 이 모든 Publisher들의 결과를 한 묶음으로 조회할 수 있다. Publisher를 최대 8개까지 넘길 수 있다. 예외나 빈값이 발견되면 즉시 에러/완료 처리된다. Flux userFluxFromStringFlux( Flux usernameFlux, Flux firstNameFlux, Flux lastNameFlux ) { return Flux.zip(usernameFlux, firstNameFlux, lastNameFlux) .map(it -> new User(it.getT1(),it.getT2(),it.getT3())); // 아래와 같이 각 결과에 이름을 붙일 수 있다. // .map((username, firstName, lastNam.. 2024. 4. 7. 이전 1 다음 반응형
