From dc8e22c698c32cefb71ecfef50123c73f8749b7c Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E1=84=8E=E1=85=AC=E1=84=89=E1=85=AE=E1=84=8B=E1=85=AF?=
 =?UTF-8?q?=E1=86=AB?= <suwon3274@gmail.com>
Date: Mon, 24 Jun 2024 18:08:44 +0900
Subject: [PATCH] =?UTF-8?q?refactor:=20Schedulers.parallel()=20=EC=82=AC?=
 =?UTF-8?q?=EC=9A=A9?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../tokenserver/application/common/async/AsyncCPUBoundTask.kt   | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/src/main/kotlin/b1nd/tokenserver/application/common/async/AsyncCPUBoundTask.kt b/src/main/kotlin/b1nd/tokenserver/application/common/async/AsyncCPUBoundTask.kt
index 7d0b50b..6d3e5d4 100644
--- a/src/main/kotlin/b1nd/tokenserver/application/common/async/AsyncCPUBoundTask.kt
+++ b/src/main/kotlin/b1nd/tokenserver/application/common/async/AsyncCPUBoundTask.kt
@@ -1,6 +1,7 @@
 package b1nd.tokenserver.application.common.async
 
 import reactor.core.publisher.Mono
+import reactor.core.scheduler.Schedulers
 import java.util.concurrent.Callable
 
 class AsyncCPUBoundTask {
@@ -9,6 +10,7 @@ class AsyncCPUBoundTask {
 
         fun <T> execute(supplier: Callable<T>): Mono<T> {
             return Mono.fromCallable(supplier)
+                .subscribeOn(Schedulers.parallel())
         }
 
     }