提交 1fd74c78 编写于 作者: Z zyyang

change

上级 7e75e5ca
......@@ -58,6 +58,12 @@
<version>2.0.13</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-context</artifactId>
<version>5.2.8.RELEASE</version>
</dependency>
</dependencies>
<repositories>
......
......@@ -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());
......
......@@ -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);
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册