Fix #184: Remove TASK_QUEUE_LIST

Author: ribasco

core/src/main/java/com/ibasco/agql/core/util/Platform.java

@@ -32,35 +32,20 @@
 import io.netty.channel.nio.NioEventLoopGroup;
 import io.netty.channel.socket.nio.NioDatagramChannel;
 import io.netty.channel.socket.nio.NioSocketChannel;
-import io.netty.util.concurrent.DefaultEventExecutorChooserFactory;
-import io.netty.util.concurrent.DefaultThreadFactory;
 import io.netty.util.concurrent.Future;
-import io.netty.util.concurrent.GenericFutureListener;
-import io.netty.util.concurrent.RejectedExecutionHandlers;
+import io.netty.util.concurrent.*;
 import io.netty.util.internal.PlatformDependent;
 import org.apache.commons.lang3.StringUtils;
 import org.jetbrains.annotations.ApiStatus;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
 import java.nio.channels.spi.SelectorProvider;
-import java.util.ArrayList;
-import java.util.List;
 import java.util.Objects;
 import java.util.Queue;
-import java.util.concurrent.BlockingQueue;
-import java.util.concurrent.ConcurrentHashMap;
-import java.util.concurrent.Executor;
-import java.util.concurrent.ExecutorService;
-import java.util.concurrent.LinkedBlockingQueue;
-import java.util.concurrent.ThreadFactory;
-import java.util.concurrent.ThreadPoolExecutor;
-import java.util.concurrent.TimeUnit;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-import static com.ibasco.agql.core.util.Console.BLUE;
-import static com.ibasco.agql.core.util.Console.CYAN;
-import static com.ibasco.agql.core.util.Console.YELLOW;
-import static com.ibasco.agql.core.util.Console.color;
-import static com.ibasco.agql.core.util.Console.printLine;
-import static com.ibasco.agql.core.util.Console.println;
+import java.util.concurrent.*;
+
+import static com.ibasco.agql.core.util.Console.*;
 
 /**
  * Platform specific implementation
@@ -74,8 +59,6 @@ public final class Platform {
 
     private static final Logger log = LoggerFactory.getLogger(Platform.class);
 
-    private static final List<Queue<Runnable>> TASK_QUEUE_LIST = new ArrayList<>();
-
     private static final Object lock = new Object();
 
     private static volatile ThreadFactory DEFAULT_THREAD_FACTORY;
@@ -344,7 +327,6 @@ private static EventLoopTaskQueueFactory getEventLoopTaskQueueFactory() {
                     DEFAULT_EVENT_QUEUE_TASKQUEUE_FACTORY = maxCapacity -> {
                         Queue<Runnable> queue = maxCapacity == Integer.MAX_VALUE ? PlatformDependent.newMpscQueue() : PlatformDependent.newMpscQueue(maxCapacity);
                         log.debug("Creating new task queue: {} ({})", queue, queue.hashCode());
-                        TASK_QUEUE_LIST.add(queue);
                         return queue;
                     };
                 }
@@ -384,15 +366,6 @@ public static ThreadGroup createThreadGroup(Class<?> cls, ThreadGroup parent) {
         }
     }
 
-    /**
-     * <p>getTaskQueueList.</p>
-     *
-     * @return a {@link java.util.List} object
-     */
-    public static List<Queue<Runnable>> getTaskQueueList() {
-        return TASK_QUEUE_LIST;
-    }
-
     /**
      * <p>Retrieves the channel class based on the provided {@link io.netty.channel.EventLoopGroup}.</p>
      *

pom.xml

@@ -30,7 +30,7 @@
 
     <!-- Properties -->
     <properties>
-        <revision>1.2.0</revision>
+        <revision>1.2.1</revision>
         <changelist>-SNAPSHOT</changelist>
         <sha1/>
         <maven.compiler.source>1.8</maven.compiler.source>