diff --git a/apm-commons/apm-datacarrier/src/main/java/org/apache/skywalking/apm/commons/datacarrier/consumer/ConsumerThread.java b/apm-commons/apm-datacarrier/src/main/java/org/apache/skywalking/apm/commons/datacarrier/consumer/ConsumerThread.java
index 1ba0223db..1e4d9c4ca 100644
--- a/apm-commons/apm-datacarrier/src/main/java/org/apache/skywalking/apm/commons/datacarrier/consumer/ConsumerThread.java
+++ b/apm-commons/apm-datacarrier/src/main/java/org/apache/skywalking/apm/commons/datacarrier/consumer/ConsumerThread.java
@@ -90,9 +90,7 @@ public class ConsumerThread<T> extends Thread {
             if (data.size() == 0) {
                 continue;
             }
-            for (T element : data) {
-                consumeList.add(element);
-            }
+            consumeList.addAll(data);
             hasData = true;
         }