From c17265fda8b67ab2129b7cc8c105d35f5c98d209 Mon Sep 17 00:00:00 2001
From: anusha <canusha835@gmail.com>
Date: Sat, 7 Mar 2026 18:17:44 +0530
Subject: [PATCH] Improve SessionPoolExample by replacing unbounded fixed
 thread pool with bounded ThreadPoolExecutor

---
 .../main/java/org/apache/iotdb/SessionPoolExample.java   | 9 ++++++++-
 1 file changed, 8 insertions(+), 1 deletion(-)

diff --git a/example/session/src/main/java/org/apache/iotdb/SessionPoolExample.java b/example/session/src/main/java/org/apache/iotdb/SessionPoolExample.java
index fa2dcf86d848..ac0258a30b76 100644
--- a/example/session/src/main/java/org/apache/iotdb/SessionPoolExample.java
+++ b/example/session/src/main/java/org/apache/iotdb/SessionPoolExample.java
@@ -72,7 +72,14 @@ public static void main(String[] args)
     // Choose the SessionPool you going to use
     constructRedirectSessionPool();
 
-    service = Executors.newFixedThreadPool(10);
+  service = new ThreadPoolExecutor(
+        10,
+        10,
+        0L,
+        TimeUnit.MILLISECONDS,
+        new ArrayBlockingQueue<>(1000),
+        new ThreadPoolExecutor.CallerRunsPolicy()
+);
     insertRecord();
     Thread.sleep(1000);
     queryByIterator();