hotfix: Queue 생성 로직이 for 바깥에 있던 점을 해결

woowa-techcamp-2024 · Aug 29, 2024 · 70ba336 · 70ba336
1 parent 2fcd23a
commit 70ba336
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 4 deletions.
diff --git a/logbat/src/main/java/info/logbat/domain/log/repository/AsyncMultiProcessor.java b/logbat/src/main/java/info/logbat/domain/log/repository/AsyncMultiProcessor.java
@@ -57,12 +57,14 @@ public void produce(List<E> data) {
     }
 
     private void setup(int queueCount, Long timeout, Integer bulkSize, int poolSize) {
-        ReentrantLogQueue<E> queue = objectProvider.getObject(timeout, bulkSize);
         for (int i = 0; i < queueCount; i++) {
-            ExecutorService leaderExecutor = Executors.newFixedThreadPool(poolSize);
+            ReentrantLogQueue<E> queue = objectProvider.getObject(timeout, bulkSize);
             queues.add(queue);
+
+            ExecutorService leaderExecutor = Executors.newFixedThreadPool(poolSize);
             leaderExecutors.add(leaderExecutor);
             flatterExecutors.add(Executors.newSingleThreadExecutor());
+
             CompletableFuture.runAsync(() -> leaderTask(queue, leaderExecutor));
         }
     }

diff --git a/logbat/src/main/resources/application.yml b/logbat/src/main/resources/application.yml
@@ -6,8 +6,8 @@ spring:
     active: local
 jdbc:
   async:
-    timeout: 2000
-    bulk-size: 100
+    timeout: 5000
+    bulk-size: 3000
 ---
 spring:
   config: