Separate executors

amplitude · Sep 27, 2024 · 95463bf · 95463bf
1 parent 89918ca
commit 95463bf
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/src/main/java/com/amplitude/HttpTransport.java b/src/main/java/com/amplitude/HttpTransport.java
@@ -46,7 +46,8 @@ class HttpTransport {
 
   // Managed by setters
   private ExecutorService retryThreadPool = Executors.newFixedThreadPool(10);
-  private ExecutorService sendThreadPool = Executors.newFixedThreadPool(40);
+  private ExecutorService sendThreadPool = Executors.newFixedThreadPool(20);
+  private ExecutorService supplyAsyncPool = Executors.newCachedThreadPool();
 
   HttpTransport(
       HttpCall httpCall, AmplitudeCallbacks callbacks, AmplitudeLog logger, long flushTimeout) {
@@ -126,7 +127,7 @@ private CompletableFuture<Response> sendEvents(List<Event> events) {
             throw new CompletionException(e);
           }
           return response;
-        }, sendThreadPool);
+        }, supplyAsyncPool);
   }
 
   // Call this function if event not in current Retry list.