[pinpoint-apm#9932] Removed thrift dependency of Agent module`

Author: emeroad

commons-profiler/src/main/java/com/navercorp/pinpoint/common/profiler/concurrent/executor/AsyncQueueingExecutor.java

@@ -33,7 +33,6 @@
 public class AsyncQueueingExecutor<T> {
 
     private final Logger logger;
-    private final boolean isWarn;
 
     private final LinkedBlockingQueue<T> queue;
     private final AtomicBoolean isRun = new AtomicBoolean(true);
@@ -51,7 +50,6 @@ public AsyncQueueingExecutor(int queueSize, String executorName, AsyncQueueingEx
         Objects.requireNonNull(executorName, "executorName");
 
         this.logger = LogManager.getLogger(this.getClass().getName() + "@" + executorName);
-        this.isWarn = logger.isWarnEnabled();
 
         // BEFORE executeThread start
         this.maxDrainSize = 10;
@@ -66,27 +64,27 @@ public AsyncQueueingExecutor(int queueSize, String executorName, AsyncQueueingEx
 
     private Thread createExecuteThread(String executorName) {
         final ThreadFactory threadFactory = new PinpointThreadFactory(executorName, true);
-        Thread thread = threadFactory.newThread(this::doAccept);
+        Thread thread = threadFactory.newThread(this::doExecute);
         thread.start();
         return thread;
     }
 
-    private void doAccept() {
+    private void doExecute() {
         long timeout = 2000;
         drainStartEntry:
         while (isRun()) {
             try {
                 final Collection<T> dtoList = getDrainQueue();
                 final int drainSize = takeN(dtoList, this.maxDrainSize);
                 if (drainSize > 0) {
-                    doAccept(dtoList);
+                    doExecute(dtoList);
                     continue;
                 }
 
                 while (isRun()) {
                     final T dto = takeOne(timeout);
                     if (dto != null) {
-                        doAccept(dto);
+                        doExecute(dto);
                         continue drainStartEntry;
                     } else {
                         pollTimeout(timeout);
@@ -113,7 +111,7 @@ private void flushQueue() {
             if (debugEnabled) {
                 logger.debug("flushData size {}", drainSize);
             }
-            doAccept(elementList);
+            doExecute(elementList);
         }
     }
 
@@ -136,32 +134,26 @@ protected void pollTimeout(long timeout) {
 
     public boolean execute(T data) {
         if (data == null) {
-            if (isWarn) {
-                logger.warn("execute(). data is null");
-            }
+            logger.warn("execute(). data is null");
             return false;
         }
         if (!isRun.get()) {
-            if (isWarn) {
-                logger.warn("{} is shutdown. discard data:{}", executorName, data);
-            }
+            logger.warn("{} is shutdown. discard data:{}", executorName, data);
             return false;
         }
         boolean offer = queue.offer(data);
         if (!offer) {
-            if (isWarn) {
-                logger.warn("{} Drop data. queue is full. size:{}", executorName, queue.size());
-            }
+            logger.warn("{} Drop data. queue is full. size:{}", executorName, queue.size());
         }
         return offer;
     }
 
 
-    private void doAccept(Collection<T> elements) {
+    private void doExecute(Collection<T> elements) {
         this.listener.execute(elements);
     }
 
-    private void doAccept(T element) {
+    private void doExecute(T element) {
         this.listener.execute(element);
     }