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);
                     });