From 1b022df572347c352805e31ed7053e5d40971253 Mon Sep 17 00:00:00 2001 From: KirillPamPam Date: Tue, 10 Dec 2024 16:09:56 +0400 Subject: [PATCH] Change queue impl (#605) --- foundation/src/main/resources/public | 2 +- .../io/emeraldpay/dshackle/config/context/SchedulersConfig.kt | 4 ++-- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/foundation/src/main/resources/public b/foundation/src/main/resources/public index 7d701484..fa32d4b5 160000 --- a/foundation/src/main/resources/public +++ b/foundation/src/main/resources/public @@ -1 +1 @@ -Subproject commit 7d7014843a9d2dfcc153b16cb677dc2790e066ae +Subproject commit fa32d4b5fd596380ae54adb2d675a07f8201fb46 diff --git a/src/main/kotlin/io/emeraldpay/dshackle/config/context/SchedulersConfig.kt b/src/main/kotlin/io/emeraldpay/dshackle/config/context/SchedulersConfig.kt index bc3e90d5..ae4b068a 100644 --- a/src/main/kotlin/io/emeraldpay/dshackle/config/context/SchedulersConfig.kt +++ b/src/main/kotlin/io/emeraldpay/dshackle/config/context/SchedulersConfig.kt @@ -12,7 +12,7 @@ import reactor.core.scheduler.Scheduler import reactor.core.scheduler.Schedulers import java.util.concurrent.Executor import java.util.concurrent.ExecutorService -import java.util.concurrent.SynchronousQueue +import java.util.concurrent.LinkedBlockingQueue import java.util.concurrent.ThreadPoolExecutor import java.util.concurrent.TimeUnit @@ -91,7 +91,7 @@ open class SchedulersConfig { size * threadsMultiplier, 60L, TimeUnit.SECONDS, - SynchronousQueue(), + LinkedBlockingQueue(1000), CustomizableThreadFactory("$name-"), )