|
@@ -65,7 +65,7 @@ public class TableStoreUtils {
|
|
|
public void initTaskExecutor(){
|
|
|
taskExecutor = new ThreadPoolTaskExecutor();
|
|
|
//设置线程池参数
|
|
|
- taskExecutor.setCorePoolSize(1);
|
|
|
+ taskExecutor.setCorePoolSize(30);
|
|
|
taskExecutor.setMaxPoolSize(100);
|
|
|
taskExecutor.setQueueCapacity(1000000);
|
|
|
taskExecutor.initialize();
|
|
@@ -152,6 +152,8 @@ public class TableStoreUtils {
|
|
|
final int num = i;
|
|
|
List<String> tempPkList = pkValuePartitionList.get(i);
|
|
|
List<List<Column>> tempColumnsList = columnsPartitionList.get(i);
|
|
|
+
|
|
|
+
|
|
|
taskExecutor.execute(()->{
|
|
|
long begin = System.currentTimeMillis();
|
|
|
log.info("第"+num+"个任务开始");
|