From b8e5ff516c71a7b6da970deaf4cfdcf852dc6d49 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E6=9D=8E=E6=96=87=E5=B9=BF?= <liwenguang_dev@163.com>
Date: Sun, 9 Aug 2020 16:21:36 +0800
Subject: [PATCH] Remove Buffer redundant strategy judgment code. (#5277)

---
 .../apm/commons/datacarrier/buffer/Buffer.java       | 12 ++++--------
 1 file changed, 4 insertions(+), 8 deletions(-)

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 d1f9217a1..b2f97c31c 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);
     }