From 1d42c83f7629a809674e4d74e6a250a5bdd43db8 Mon Sep 17 00:00:00 2001 From: Paolo Di Tommaso Date: Tue, 26 Nov 2024 23:22:46 +0100 Subject: [PATCH] Use v-threads for AbstractFutureStore 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: