Change queue impl (#605)

2024-12-10 16:09:56 +04:00
parent de2a734aa4
commit 1b022df572
2 changed files with 3 additions and 3 deletions
--- a/foundation/src/main/resources/public
+++ b/foundation/src/main/resources/public
--- 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-"),
        )