Skip to content

Commit 59e1516

Browse files
committed
fix: add keepAliveTime to close idle threads
1 parent 3afbc3e commit 59e1516

File tree

1 file changed

+7
-1
lines changed

1 file changed

+7
-1
lines changed

src/main/java/com/google/firebase/internal/FirebaseThreadManagers.java

Lines changed: 7 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -23,7 +23,10 @@
2323
import java.util.Set;
2424
import java.util.concurrent.ExecutorService;
2525
import java.util.concurrent.Executors;
26+
import java.util.concurrent.LinkedBlockingQueue;
2627
import java.util.concurrent.ThreadFactory;
28+
import java.util.concurrent.ThreadPoolExecutor;
29+
import java.util.concurrent.TimeUnit;
2730

2831
import org.slf4j.Logger;
2932
import org.slf4j.LoggerFactory;
@@ -85,7 +88,10 @@ protected ExecutorService doInit() {
8588
ThreadFactory threadFactory = FirebaseScheduledExecutor.getThreadFactoryWithName(
8689
getThreadFactory(), "firebase-default-%d");
8790

88-
return Executors.newFixedThreadPool(100, threadFactory);
91+
ThreadPoolExecutor threadPoolExecutor = new ThreadPoolExecutor(100, 100, 60L,
92+
TimeUnit.SECONDS, new LinkedBlockingQueue<Runnable>(), threadFactory);
93+
threadPoolExecutor.allowCoreThreadTimeOut(true);
94+
return threadPoolExecutor;
8995
}
9096

9197
@Override

0 commit comments

Comments
 (0)