From d29d4df419469666e26825d9d941be344185de5a Mon Sep 17 00:00:00 2001 From: Paolo Di Tommaso Date: Sun, 17 Nov 2024 18:38:05 +0100 Subject: [PATCH] Migration to virtual threads - phase 4 Signed-off-by: Paolo Di Tommaso --- .../seqera/wave/service/data/future/AbstractFutureStore.groovy | 3 ++- src/main/resources/application.yml | 3 --- 2 files changed, 2 insertions(+), 4 deletions(-) diff --git a/src/main/groovy/io/seqera/wave/service/data/future/AbstractFutureStore.groovy b/src/main/groovy/io/seqera/wave/service/data/future/AbstractFutureStore.groovy index 130efe56d..f81dd27fa 100644 --- a/src/main/groovy/io/seqera/wave/service/data/future/AbstractFutureStore.groovy +++ b/src/main/groovy/io/seqera/wave/service/data/future/AbstractFutureStore.groovy @@ -26,6 +26,7 @@ import java.util.concurrent.TimeoutException import groovy.transform.CompileStatic import groovy.util.logging.Slf4j import io.micronaut.context.annotation.Value +import io.micronaut.scheduling.TaskExecutors import io.seqera.wave.encoder.EncodingStrategy import jakarta.inject.Inject import jakarta.inject.Named @@ -55,7 +56,7 @@ abstract class AbstractFutureStore implements FutureStore { private volatile Duration pollInterval @Inject - @Named('future-store-executor') + @Named(TaskExecutors.BLOCKING) private ExecutorService executor AbstractFutureStore(FutureHash store, EncodingStrategy encodingStrategy) { diff --git a/src/main/resources/application.yml b/src/main/resources/application.yml index bd030f589..4c7e565b8 100644 --- a/src/main/resources/application.yml +++ b/src/main/resources/application.yml @@ -41,9 +41,6 @@ micronaut: stream-executor: type: FIXED number-of-threads: 16 - future-store-executor: - type : FIXED - number-of-threads : 32 netty: event-loops: stream-pool: