diff --git a/apm-commons/apm-datacarrier/src/main/java/org/apache/skywalking/apm/commons/datacarrier/buffer/Buffer.java b/apm-commons/apm-datacarrier/src/main/java/org/apache/skywalking/apm/commons/datacarrier/buffer/Buffer.java
index d1f9217a1b57d06d090267758837d911da6a1b56..b2f97c31cdbfa1fc82ba425f296087e9690df19a 100644
--- a/apm-commons/apm-datacarrier/src/main/java/org/apache/skywalking/apm/commons/datacarrier/buffer/Buffer.java
+++ b/apm-commons/apm-datacarrier/src/main/java/org/apache/skywalking/apm/commons/datacarrier/buffer/Buffer.java
@@ -35,22 +35,16 @@ public class Buffer<T> implements QueueBuffer<T> {
         index = new AtomicRangeInteger(0, bufferSize);
     }
 
+    @Override
     public void setStrategy(BufferStrategy strategy) {
         this.strategy = strategy;
     }
 
+    @Override
     public boolean save(T data) {
         int i = index.getAndIncrement();
         if (buffer[i] != null) {
             switch (strategy) {
-                case BLOCKING:
-                    while (buffer[i] != null) {
-                        try {
-                            Thread.sleep(1L);
-                        } catch (InterruptedException e) {
-                        }
-                    }
-                    break;
                 case IF_POSSIBLE:
                     return false;
                 default:
@@ -60,10 +54,12 @@ public class Buffer<T> implements QueueBuffer<T> {
         return true;
     }
 
+    @Override
     public int getBufferSize() {
         return buffer.length;
     }
 
+    @Override
     public void obtain(List<T> consumeList) {
         this.obtain(consumeList, 0, buffer.length);
     }