[apache#6562] improvement(catalogs): Optimize the code path in createFileset and optimize path

Set the number of core threads and queue size, and set the idle time.

Author: Abyss-lord

catalogs/catalog-hadoop/src/main/java/org/apache/gravitino/catalog/hadoop/HadoopCatalogOperations.java

@@ -32,9 +32,9 @@
 import java.util.Map;
 import java.util.Optional;
 import java.util.concurrent.ExecutionException;
-import java.util.concurrent.ExecutorService;
-import java.util.concurrent.Executors;
 import java.util.concurrent.Future;
+import java.util.concurrent.LinkedBlockingQueue;
+import java.util.concurrent.ThreadPoolExecutor;
 import java.util.concurrent.TimeUnit;
 import java.util.concurrent.TimeoutException;
 import org.apache.commons.lang3.StringUtils;
@@ -84,9 +84,13 @@ public class HadoopCatalogOperations extends ManagedSchemaOperations
     implements CatalogOperations, FilesetCatalog {
   private static final String SCHEMA_DOES_NOT_EXIST_MSG = "Schema %s does not exist";
   private static final String FILESET_DOES_NOT_EXIST_MSG = "Fileset %s does not exist";
-  private static final ExecutorService FILE_SYSTEM_EXECUTOR =
-      Executors.newFixedThreadPool(
+  private static final ThreadPoolExecutor FILE_SYSTEM_EXECUTOR =
+      new ThreadPoolExecutor(
+          2,
           Math.max(2, Runtime.getRuntime().availableProcessors() / 2),
+          60L,
+          TimeUnit.SECONDS,
+          new LinkedBlockingQueue<>(100),
           r -> {
             Thread thread = new Thread(r, "FileSystem-Get-Thread");
             thread.setDaemon(true);
@@ -110,6 +114,10 @@ public class HadoopCatalogOperations extends ManagedSchemaOperations
 
   private FileSystemProvider defaultFileSystemProvider;
 
+  static {
+    FILE_SYSTEM_EXECUTOR.allowCoreThreadTimeOut(true);
+  }
+
   HadoopCatalogOperations(EntityStore store) {
     this.store = store;
   }