[ISSUE#8485] (module-common) replace the type specification in this constructor call with the diamond operator ("<>") (#8554)

common/src/main/java/com/alibaba/nacos/common/executor/ExecutorFactory.java

@@ -68,7 +68,7 @@ public final class ExecutorFactory {
     public static ThreadPoolExecutor newCustomerThreadExecutor(final int coreThreads, final int maxThreads,
             final long keepAliveTimeMs, final ThreadFactory threadFactory) {
         return new ThreadPoolExecutor(coreThreads, maxThreads, keepAliveTimeMs, TimeUnit.MILLISECONDS,
-                new LinkedBlockingQueue<Runnable>(), threadFactory);
+                new LinkedBlockingQueue<>(), threadFactory);
     }
     
     public static final class Managed {
@@ -172,7 +172,7 @@ public final class ExecutorFactory {
         public static ThreadPoolExecutor newCustomerThreadExecutor(final String group, final int coreThreads,
                 final int maxThreads, final long keepAliveTimeMs, final ThreadFactory threadFactory) {
             ThreadPoolExecutor executor = new ThreadPoolExecutor(coreThreads, maxThreads, keepAliveTimeMs,
-                    TimeUnit.MILLISECONDS, new LinkedBlockingQueue<Runnable>(), threadFactory);
+                    TimeUnit.MILLISECONDS, new LinkedBlockingQueue<>(), threadFactory);
             THREAD_POOL_MANAGER.register(DEFAULT_NAMESPACE, group, executor);
             return executor;
         }

common/src/main/java/com/alibaba/nacos/common/executor/ThreadPoolManager.java

@@ -44,7 +44,7 @@ public final class ThreadPoolManager {
     
     private Map<String, Map<String, Set<ExecutorService>>> resourcesManager;
     
-    private Map<String, Object> lockers = new ConcurrentHashMap<String, Object>(8);
+    private Map<String, Object> lockers = new ConcurrentHashMap<>(8);
     
     private static final ThreadPoolManager INSTANCE = new ThreadPoolManager();
     
@@ -67,7 +67,7 @@ public final class ThreadPoolManager {
     }
     
     private void init() {
-        resourcesManager = new ConcurrentHashMap<String, Map<String, Set<ExecutorService>>>(8);
+        resourcesManager = new ConcurrentHashMap<>(8);
     }
     
     /**
@@ -85,7 +85,7 @@ public final class ThreadPoolManager {
         synchronized (monitor) {
             Map<String, Set<ExecutorService>> map = resourcesManager.get(namespace);
             if (map == null) {
-                map = new HashMap<String, Set<ExecutorService>>(8);
+                map = new HashMap<>(8);
                 map.computeIfAbsent(group, key -> new HashSet<>()).add(executor);
                 resourcesManager.put(namespace, map);
                 return;

common/src/main/java/com/alibaba/nacos/common/http/HttpClientBeanHolder.java

@@ -36,9 +36,9 @@ public final class HttpClientBeanHolder {
     
     private static final Logger LOGGER = LoggerFactory.getLogger(HttpClientBeanHolder.class);
     
-    private static final Map<String, NacosRestTemplate> SINGLETON_REST = new HashMap<String, NacosRestTemplate>(10);
+    private static final Map<String, NacosRestTemplate> SINGLETON_REST = new HashMap<>(10);
     
-    private static final Map<String, NacosAsyncRestTemplate> SINGLETON_ASYNC_REST = new HashMap<String, NacosAsyncRestTemplate>(
+    private static final Map<String, NacosAsyncRestTemplate> SINGLETON_ASYNC_REST = new HashMap<>(
             10);
     
     private static final AtomicBoolean ALREADY_SHUTDOWN = new AtomicBoolean(false);

common/src/main/java/com/alibaba/nacos/common/http/HttpUtils.java

@@ -114,7 +114,7 @@ public final class HttpUtils {
         if (body == null || body.isEmpty()) {
             return;
         }
-        List<NameValuePair> params = new ArrayList<NameValuePair>(body.size());
+        List<NameValuePair> params = new ArrayList<>(body.size());
         for (Map.Entry<String, String> entry : body.entrySet()) {
             params.add(new BasicNameValuePair(entry.getKey(), entry.getValue()));
         }
@@ -176,7 +176,7 @@ public final class HttpUtils {
      * @throws Exception exception
      */
     public static Map<String, String> translateParameterMap(Map<String, String[]> parameterMap) throws Exception {
-        Map<String, String> map = new HashMap<String, String>(16);
+        Map<String, String> map = new HashMap<>(16);
         for (Map.Entry<String, String[]> entry : parameterMap.entrySet()) {
             map.put(entry.getKey(), entry.getValue()[0]);
         }

common/src/main/java/com/alibaba/nacos/common/http/client/NacosRestTemplate.java

@@ -49,7 +49,7 @@ public class NacosRestTemplate extends AbstractNacosRestTemplate {
     
     private final HttpClientRequest requestClient;
     
-    private final List<HttpClientRequestInterceptor> interceptors = new ArrayList<HttpClientRequestInterceptor>();
+    private final List<HttpClientRequestInterceptor> interceptors = new ArrayList<>();
     
     public NacosRestTemplate(Logger logger, HttpClientRequest requestClient) {
         super(logger);

common/src/main/java/com/alibaba/nacos/common/http/client/handler/AbstractResponseHandler.java

@@ -49,7 +49,7 @@ public abstract class AbstractResponseHandler<T> implements ResponseHandler<T> {
     private HttpRestResult<T> handleError(HttpClientResponse response) throws Exception {
         Header headers = response.getHeaders();
         String message = IoUtils.toString(response.getBody(), headers.getCharset());
-        return new HttpRestResult<T>(headers, response.getStatusCode(), null, message);
+        return new HttpRestResult<>(headers, response.getStatusCode(), null, message);
     }
     
     /**

common/src/main/java/com/alibaba/nacos/common/http/client/handler/BeanResponseHandler.java

@@ -37,6 +37,6 @@ public class BeanResponseHandler<T> extends AbstractResponseHandler<T> {
         final Header headers = response.getHeaders();
         InputStream body = response.getBody();
         T extractBody = JacksonUtils.toObj(body, responseType);
-        return new HttpRestResult<T>(headers, response.getStatusCode(), extractBody, null);
+        return new HttpRestResult<>(headers, response.getStatusCode(), extractBody, null);
     }
 }

common/src/main/java/com/alibaba/nacos/common/http/client/handler/RestResultResponseHandler.java

@@ -44,7 +44,7 @@ public class RestResultResponseHandler<T> extends AbstractResponseHandler<T> {
     }
     
     private static <T> HttpRestResult<T> convert(RestResult<T> restResult) {
-        HttpRestResult<T> httpRestResult = new HttpRestResult<T>();
+        HttpRestResult<T> httpRestResult = new HttpRestResult<>();
         httpRestResult.setCode(restResult.getCode());
         httpRestResult.setData(restResult.getData());
         httpRestResult.setMessage(restResult.getMessage());

common/src/main/java/com/alibaba/nacos/common/http/client/handler/StringResponseHandler.java

@@ -34,6 +34,6 @@ public class StringResponseHandler extends AbstractResponseHandler<String> {
     public HttpRestResult<String> convertResult(HttpClientResponse response, Type responseType) throws Exception {
         final Header headers = response.getHeaders();
         String extractBody = IoUtils.toString(response.getBody(), headers.getCharset());
-        return new HttpRestResult<String>(headers, response.getStatusCode(), extractBody, null);
+        return new HttpRestResult<>(headers, response.getStatusCode(), extractBody, null);
     }
 }

common/src/main/java/com/alibaba/nacos/common/http/param/Header.java

@@ -45,8 +45,8 @@ public class Header {
     private static final String DEFAULT_ENCODING = "gzip";
     
     private Header() {
-        header = new TreeMap<String, String>(String.CASE_INSENSITIVE_ORDER);
+        header = new TreeMap<>(String.CASE_INSENSITIVE_ORDER);
-        originalResponseHeader = new TreeMap<String, List<String>>(String.CASE_INSENSITIVE_ORDER);
+        originalResponseHeader = new TreeMap<>(String.CASE_INSENSITIVE_ORDER);
         addParam(HttpHeaderConsts.CONTENT_TYPE, MediaType.APPLICATION_JSON);
         addParam(HttpHeaderConsts.ACCEPT_CHARSET, DEFAULT_CHARSET);
         //addParam(HttpHeaderConsts.ACCEPT_ENCODING, DEFAULT_ENCODING);
@@ -99,7 +99,7 @@ public class Header {
      * @return KV string list
      */
     public List<String> toList() {
-        List<String> list = new ArrayList<String>(header.size() * 2);
+        List<String> list = new ArrayList<>(header.size() * 2);
         Iterator<Map.Entry<String, String>> iterator = iterator();
         while (iterator.hasNext()) {
             Map.Entry<String, String> entry = iterator.next();

common/src/main/java/com/alibaba/nacos/common/http/param/Query.java

@@ -41,7 +41,7 @@ public class Query {
     private static final String DEFAULT_ENC = "UTF-8";
     
     public Query() {
-        params = new LinkedHashMap<String, Object>();
+        params = new LinkedHashMap<>();
     }
     
     public static Query newInstance() {

common/src/main/java/com/alibaba/nacos/common/model/RestResult.java

@@ -86,7 +86,7 @@ public class RestResult<T> implements Serializable {
     }
     
     public static <T> ResResultBuilder<T> builder() {
-        return new ResResultBuilder<T>();
+        return new ResResultBuilder<>();
     }
     
     public static final class ResResultBuilder<T> {
@@ -121,7 +121,7 @@ public class RestResult<T> implements Serializable {
          * @return result
          */
         public RestResult<T> build() {
-            RestResult<T> restResult = new RestResult<T>();
+            RestResult<T> restResult = new RestResult<>();
             restResult.setCode(code);
             restResult.setMessage(errMsg);
             restResult.setData(data);

common/src/main/java/com/alibaba/nacos/common/notify/DefaultSharePublisher.java

@@ -47,7 +47,7 @@ public class DefaultSharePublisher extends DefaultPublisher implements ShardedEv
         try {
             Set<Subscriber> sets = subMappings.get(subSlowEventType);
             if (sets == null) {
-                Set<Subscriber> newSet = new ConcurrentHashSet<Subscriber>();
+                Set<Subscriber> newSet = new ConcurrentHashSet<>();
                 newSet.add(subscriber);
                 subMappings.put(subSlowEventType, newSet);
                 return;

common/src/main/java/com/alibaba/nacos/common/spi/NacosServiceLoader.java

@@ -30,7 +30,7 @@ import java.util.concurrent.ConcurrentHashMap;
  */
 public class NacosServiceLoader {
     
-    private static final Map<Class<?>, Collection<Class<?>>> SERVICES = new ConcurrentHashMap<Class<?>, Collection<Class<?>>>();
+    private static final Map<Class<?>, Collection<Class<?>>> SERVICES = new ConcurrentHashMap<>();
     
     /**
      * Load service.
@@ -45,7 +45,7 @@ public class NacosServiceLoader {
         if (SERVICES.containsKey(service)) {
             return newServiceInstances(service);
         }
-        Collection<T> result = new LinkedHashSet<T>();
+        Collection<T> result = new LinkedHashSet<>();
         for (T each : ServiceLoader.load(service)) {
             result.add(each);
             cacheServiceClass(service, each);
@@ -55,7 +55,7 @@ public class NacosServiceLoader {
     
     private static <T> void cacheServiceClass(final Class<T> service, final T instance) {
         if (!SERVICES.containsKey(service)) {
-            SERVICES.put(service, new LinkedHashSet<Class<?>>());
+            SERVICES.put(service, new LinkedHashSet<>());
         }
         SERVICES.get(service).add(instance.getClass());
     }
@@ -73,7 +73,7 @@ public class NacosServiceLoader {
     
     @SuppressWarnings("unchecked")
     private static <T> Collection<T> newServiceInstancesFromCache(Class<T> service) {
-        Collection<T> result = new LinkedHashSet<T>();
+        Collection<T> result = new LinkedHashSet<>();
         for (Class<?> each : SERVICES.get(service)) {
             result.add((T) newServiceInstance(each));
         }

common/src/main/java/com/alibaba/nacos/common/task/engine/NacosDelayTaskExecuteEngine.java

@@ -104,7 +104,7 @@ public class NacosDelayTaskExecuteEngine extends AbstractNacosTaskExecuteEngine<
     
     @Override
     public Collection<Object> getAllTaskKeys() {
-        Collection<Object> keys = new HashSet<Object>();
+        Collection<Object> keys = new HashSet<>();
         lock.lock();
         try {
             keys.addAll(tasks.keySet());

common/src/main/java/com/alibaba/nacos/common/task/engine/TaskExecuteWorker.java

@@ -54,7 +54,7 @@ public final class TaskExecuteWorker implements NacosTaskProcessor, Closeable {
     
     public TaskExecuteWorker(final String name, final int mod, final int total, final Logger logger) {
         this.name = name + "_" + mod + "%" + total;
-        this.queue = new ArrayBlockingQueue<Runnable>(QUEUE_CAPACITY);
+        this.queue = new ArrayBlockingQueue<>(QUEUE_CAPACITY);
         this.closed = new AtomicBoolean(false);
         this.log = null == logger ? LoggerFactory.getLogger(TaskExecuteWorker.class) : logger;
         new InnerWorker(name).start();

common/src/main/java/com/alibaba/nacos/common/utils/ConcurrentHashSet.java

@@ -31,7 +31,7 @@ public class ConcurrentHashSet<E> extends AbstractSet<E> {
     
     public ConcurrentHashSet() {
         super();
-        map = new ConcurrentHashMap<E, Boolean>();
+        map = new ConcurrentHashMap<>();
     }
     
     @Override

common/src/main/java/com/alibaba/nacos/common/utils/IoUtils.java

@@ -149,7 +149,7 @@ public class IoUtils {
      */
     public static List<String> readLines(Reader input) throws IOException {
         BufferedReader reader = toBufferedReader(input);
-        List<String> list = new ArrayList<String>();
+        List<String> list = new ArrayList<>();
         String line = null;
         for (; ; ) {
             line = reader.readLine();

common/src/main/java/com/alibaba/nacos/common/utils/Observable.java

@@ -28,7 +28,7 @@ public class Observable {
     
     private transient boolean changed = false;
     
-    private transient Set<Observer> obs = new ConcurrentHashSet<Observer>();
+    private transient Set<Observer> obs = new ConcurrentHashSet<>();
     
     private volatile int observerCnt = 0;