From f9fe2d4d18ee9df045b605ffcb3e73822f4e2e7d Mon Sep 17 00:00:00 2001 From: wusheng Date: Thu, 21 Jul 2016 11:35:11 +0800 Subject: [PATCH] =?UTF-8?q?=E7=A7=BB=E5=8A=A8BufferPool=E4=BB=A3=E7=A0=81?= =?UTF-8?q?=E4=BD=8D=E7=BD=AE=EF=BC=8C=E5=A2=9E=E5=8A=A0=E5=8F=AF=E8=AF=BB?= =?UTF-8?q?=E6=80=A7=E3=80=82?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../cloud/skywalking/buffer/BufferPool.java | 26 +++++++++++++++++++ .../skywalking/buffer/ContextBuffer.java | 16 ------------ .../protocol/util/AtomicRangeInteger.java | 4 +-- 3 files changed, 28 insertions(+), 18 deletions(-) create mode 100644 skywalking-collector/skywalking-api/src/main/java/com/ai/cloud/skywalking/buffer/BufferPool.java diff --git a/skywalking-collector/skywalking-api/src/main/java/com/ai/cloud/skywalking/buffer/BufferPool.java b/skywalking-collector/skywalking-api/src/main/java/com/ai/cloud/skywalking/buffer/BufferPool.java new file mode 100644 index 000000000..4f22bb414 --- /dev/null +++ b/skywalking-collector/skywalking-api/src/main/java/com/ai/cloud/skywalking/buffer/BufferPool.java @@ -0,0 +1,26 @@ +package com.ai.cloud.skywalking.buffer; + +import com.ai.cloud.skywalking.protocol.common.ISerializable; + +import java.util.concurrent.ThreadLocalRandom; + +import static com.ai.cloud.skywalking.conf.Config.Buffer.POOL_SIZE; + +/** + * Created by wusheng on 16/7/21. + */ +class BufferPool { + // 注意： 这个变量名如果改变需要改变test-api工程中的Config变量 + private static BufferGroup[] bufferGroups = new BufferGroup[POOL_SIZE]; + static { + for (int i = 0; i < POOL_SIZE; i++) { + bufferGroups[i] = new BufferGroup("buffer_group-" + i); + } + } + + public void save(ISerializable data) { + bufferGroups[ThreadLocalRandom.current().nextInt(0, POOL_SIZE)].save(data); + } + + +} diff --git a/skywalking-collector/skywalking-api/src/main/java/com/ai/cloud/skywalking/buffer/ContextBuffer.java b/skywalking-collector/skywalking-api/src/main/java/com/ai/cloud/skywalking/buffer/ContextBuffer.java index 9883a8545..402f867cf 100644 --- a/skywalking-collector/skywalking-api/src/main/java/com/ai/cloud/skywalking/buffer/ContextBuffer.java +++ b/skywalking-collector/skywalking-api/src/main/java/com/ai/cloud/skywalking/buffer/ContextBuffer.java @@ -25,22 +25,6 @@ public class ContextBuffer { logger.error("save span error.", t); } } - - - static class BufferPool { - // 注意： 这个变量名如果改变需要改变test-api工程中的Config变量 - private static BufferGroup[] bufferGroups = new BufferGroup[POOL_SIZE]; - static { - for (int i = 0; i < POOL_SIZE; i++) { - bufferGroups[i] = new BufferGroup("buffer_group-" + i); - } - } - - public void save(ISerializable data) { - bufferGroups[ThreadLocalRandom.current().nextInt(0, POOL_SIZE)].save(data); - } - - } } diff --git a/skywalking-collector/skywalking-protocol/src/main/java/com/ai/cloud/skywalking/protocol/util/AtomicRangeInteger.java b/skywalking-collector/skywalking-protocol/src/main/java/com/ai/cloud/skywalking/protocol/util/AtomicRangeInteger.java index 7160acc79..d5ed69379 100644 --- a/skywalking-collector/skywalking-protocol/src/main/java/com/ai/cloud/skywalking/protocol/util/AtomicRangeInteger.java +++ b/skywalking-collector/skywalking-protocol/src/main/java/com/ai/cloud/skywalking/protocol/util/AtomicRangeInteger.java @@ -19,9 +19,9 @@ public class AtomicRangeInteger extends Number implements java.io.Serializable { /** * Creates a new AtomicInteger with the given initial value and max value * - * @param initialValue + * @param startValue * the initial value - * @param endValue + * @param maxValue * * AtomicRangeInteger在startValue和maxValue循环取值（ startValue <= value < maxValue） */