From 596f8c673c6f1e09018baa74aeab513ac0ed5c0c Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E5=86=B7=E8=B0=83?= <3084898776@qq.com>
Date: Wed, 4 Sep 2024 19:58:18 +0800
Subject: [PATCH] =?UTF-8?q?09041958:=E4=BC=98=E5=8C=96=E5=90=8C=E6=AD=A5?=
 =?UTF-8?q?=E8=B5=84=E4=BA=A7=E7=BB=93=E6=9E=84?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../com/muyu/source/service/Impl/DataSourceServiceImpl.java  | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git a/muyu-source-server/src/main/java/com/muyu/source/service/Impl/DataSourceServiceImpl.java b/muyu-source-server/src/main/java/com/muyu/source/service/Impl/DataSourceServiceImpl.java
index cc1fd33..796294e 100644
--- a/muyu-source-server/src/main/java/com/muyu/source/service/Impl/DataSourceServiceImpl.java
+++ b/muyu-source-server/src/main/java/com/muyu/source/service/Impl/DataSourceServiceImpl.java
@@ -137,7 +137,7 @@ public class DataSourceServiceImpl extends ServiceImpl<DataSourceMapper, DataSou
      */
     @Override
     public Integer syncAssetStructure(DataSource etlDataScore) {
-        ExecutorService threadPool = Executors.newFixedThreadPool(10);
+
         try {
             if (etlDataScore.getDataType().equals(MYSQL)) {
                 MysqlPool mysqlPool = new MysqlPool(etlDataScore);
@@ -222,6 +222,9 @@ public class DataSourceServiceImpl extends ServiceImpl<DataSourceMapper, DataSou
                     //根据数据库id和表名查询数据
                     TableInfo table = tableInfoService.selectTableInfoByName(build);
 
+
+                    ExecutorService threadPool = Executors.newCachedThreadPool();
+
                     threadPool.submit(() -> {
                         syncData(conn, etlDataScore.getDatabaseName(), table);
                     });