diff --git a/tests/examples/JDBC/connectionPools/pom.xml b/tests/examples/JDBC/connectionPools/pom.xml index 46fd4adc38dac99e653688f99f54802b79b79031..fc489f7f1d2bfc9eaca4574ef00bd8c576eb222b 100644 --- a/tests/examples/JDBC/connectionPools/pom.xml +++ b/tests/examples/JDBC/connectionPools/pom.xml @@ -58,6 +58,12 @@ 2.0.13 + + org.springframework + spring-context + 5.2.8.RELEASE + + diff --git a/tests/examples/JDBC/connectionPools/src/main/java/com/taosdata/demo/ConnectionPoolDemo.java b/tests/examples/JDBC/connectionPools/src/main/java/com/taosdata/demo/ConnectionPoolDemo.java index 0957af19d6f8d8032503ec8800fc36bf06d5a3cd..4e29e2642392db2502062b6e0cd07e6e223a5bb7 100644 --- a/tests/examples/JDBC/connectionPools/src/main/java/com/taosdata/demo/ConnectionPoolDemo.java +++ b/tests/examples/JDBC/connectionPools/src/main/java/com/taosdata/demo/ConnectionPoolDemo.java @@ -6,6 +6,7 @@ import com.taosdata.demo.pool.DbcpBuilder; import com.taosdata.demo.pool.DruidPoolBuilder; import com.taosdata.demo.pool.HikariCpBuilder; import org.apache.log4j.Logger; +import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor; import javax.sql.DataSource; import java.sql.Connection; @@ -86,7 +87,13 @@ public class ConnectionPoolDemo { logger.info(">>>>>>>>>>>>>> connection pool Type: " + poolType); init(dataSource); - ThreadPoolExecutor executor = (ThreadPoolExecutor) Executors.newFixedThreadPool(threadPoolSize); + + ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor(); + executor.setCorePoolSize(20); + executor.setMaxPoolSize(100); + executor.setQueueCapacity(100); + executor.setKeepAliveSeconds(300); +// ThreadPoolExecutor executor = (ThreadPoolExecutor) Executors.newFixedThreadPool(threadPoolSize); while (true) { executor.execute(new InsertTask(dataSource, dbName, tableSize, batchSize)); logger.info("thread pool size : " + executor.getPoolSize() + ", active pool size: " + executor.getActiveCount()); diff --git a/tests/examples/JDBC/connectionPools/src/main/java/com/taosdata/demo/pool/HikariCpBuilder.java b/tests/examples/JDBC/connectionPools/src/main/java/com/taosdata/demo/pool/HikariCpBuilder.java index 6ba43cd56364e705aab87309ccfd0dd448272961..daaad7b4640cbc599e9caf2af7c0de0ff314c9af 100644 --- a/tests/examples/JDBC/connectionPools/src/main/java/com/taosdata/demo/pool/HikariCpBuilder.java +++ b/tests/examples/JDBC/connectionPools/src/main/java/com/taosdata/demo/pool/HikariCpBuilder.java @@ -16,9 +16,6 @@ public class HikariCpBuilder { config.setMaximumPoolSize(poolSize); config.setMinimumIdle(poolSize); - - config.setMinimumIdle(3); - config.setMaximumPoolSize(500); config.setMaxLifetime(2000000); config.setConnectionTimeout(30000); config.setIdleTimeout(30000);