Format code

hippo4j-core/src/main/java/cn/hippo4j/core/executor/DynamicThreadPoolExecutor.java

@@ -80,13 +80,13 @@ public class DynamicThreadPoolExecutor extends ExtensibleThreadPoolExecutor impl
      *                                  or {@code threadFactory} or {@code handler} is null
      */
     public DynamicThreadPoolExecutor(
-            int corePoolSize, int maximumPoolSize,
+                                     int corePoolSize, int maximumPoolSize,
-            long keepAliveTime, TimeUnit unit,
+                                     long keepAliveTime, TimeUnit unit,
-            long executeTimeOut, boolean waitForTasksToCompleteOnShutdown, long awaitTerminationMillis,
+                                     long executeTimeOut, boolean waitForTasksToCompleteOnShutdown, long awaitTerminationMillis,
-            @NonNull BlockingQueue<Runnable> blockingQueue,
+                                     @NonNull BlockingQueue<Runnable> blockingQueue,
-            @NonNull String threadPoolId,
+                                     @NonNull String threadPoolId,
-            @NonNull ThreadFactory threadFactory,
+                                     @NonNull ThreadFactory threadFactory,
-            @NonNull RejectedExecutionHandler rejectedExecutionHandler) {
+                                     @NonNull RejectedExecutionHandler rejectedExecutionHandler) {
         super(
                 threadPoolId, new DefaultThreadPoolPluginManager(),
                 corePoolSize, maximumPoolSize, keepAliveTime, unit,

hippo4j-core/src/main/java/cn/hippo4j/core/executor/ExtensibleThreadPoolExecutor.java

@@ -88,13 +88,13 @@ public class ExtensibleThreadPoolExecutor extends ThreadPoolExecutor implements
      *                                  or {@code threadFactory} or {@code handler} is null
      */
     public ExtensibleThreadPoolExecutor(
-            @NonNull String threadPoolId,
+                                        @NonNull String threadPoolId,
-            @NonNull ThreadPoolPluginManager threadPoolPluginManager,
+                                        @NonNull ThreadPoolPluginManager threadPoolPluginManager,
-            int corePoolSize, int maximumPoolSize,
+                                        int corePoolSize, int maximumPoolSize,
-            long keepAliveTime, TimeUnit unit,
+                                        long keepAliveTime, TimeUnit unit,
-            @NonNull BlockingQueue<Runnable> workQueue,
+                                        @NonNull BlockingQueue<Runnable> workQueue,
-            @NonNull ThreadFactory threadFactory,
+                                        @NonNull ThreadFactory threadFactory,
-            @NonNull RejectedExecutionHandler handler) {
+                                        @NonNull RejectedExecutionHandler handler) {
         super(corePoolSize, maximumPoolSize, keepAliveTime, unit, workQueue, threadFactory, handler);
         // Pool extended info.
         this.threadPoolId = threadPoolId;

hippo4j-core/src/main/java/cn/hippo4j/core/toolkit/inet/InetUtils.java

@@ -75,7 +75,7 @@ public class InetUtils implements Closeable {
         try {
             int lowest = Integer.MAX_VALUE;
             for (Enumeration<NetworkInterface> nics = NetworkInterface
-                    .getNetworkInterfaces(); nics.hasMoreElements(); ) {
+                    .getNetworkInterfaces(); nics.hasMoreElements();) {
                 NetworkInterface ifc = nics.nextElement();
                 if (ifc.isUp()) {
                     this.log.trace("Testing interface: " + ifc.getDisplayName());
@@ -86,7 +86,7 @@ public class InetUtils implements Closeable {
                     }
                     if (!ignoreInterface(ifc.getDisplayName())) {
                         for (Enumeration<InetAddress> addrs = ifc
-                                .getInetAddresses(); addrs.hasMoreElements(); ) {
+                                .getInetAddresses(); addrs.hasMoreElements();) {
                             InetAddress address = addrs.nextElement();
                             if (address instanceof Inet4Address
                                     && !address.isLoopbackAddress()

hippo4j-server/hippo4j-config/src/main/java/cn/hippo4j/config/rpc/support/NettyConnectPoolHolder.java

@@ -84,10 +84,8 @@ public class NettyConnectPoolHolder {
      */
     public static synchronized NettyConnectPool getPool(String host, int port,
                                                         long timeout, EventLoopGroup worker) {
-        /*
+        // This cannot use the computeIfAbsent method directly here because put is already used in init.
-         * this cannot use the computeIfAbsent method directly here because put is already used in init.
+        // Details refer to https://bugs.openjdk.java.net/browse/JDK-8062841
-         * Details refer to https://bugs.openjdk.java.net/browse/JDK-8062841
-         */
         NettyConnectPool pool = getPool(host, port);
         return pool == null ? initPool(host, port, timeout, worker) : pool;
     }