refactor: Schedulers.parallel() 사용

Team-B1ND · Jun 24, 2024 · dc8e22c · dc8e22c
1 parent d354bf9
commit dc8e22c
Showing 1 changed file with 2 additions and 0 deletions.
diff --git 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())
  }
 
  }