kazusa
/
skywalking-java
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

同上

This commit is contained in:
zhangxin10 2015-11-17 16:24:09 +08:00
parent 53aa84edc0
commit aeb1439cde
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
skywalking-api/src/main/java/com/ai/cloud/skywalking/buffer/ContextBuffer.java
View File

@ -4,7 +4,7 @@ import com.ai.cloud.skywalking.context.Span;
import java.util.concurrent.ThreadLocalRandom;
import static com.ai.cloud.skywalking.conf.Config.Buffer.POOL_MAX_LENGTH;
import static com.ai.cloud.skywalking.conf.Config.Buffer.POOL_SIZE;
public class ContextBuffer {
@ -20,15 +20,15 @@ public class ContextBuffer {
static class BufferPool {
private static BufferGroup[] bufferGroups = new BufferGroup[POOL_MAX_LENGTH];
private static BufferGroup[] bufferGroups = new BufferGroup[POOL_SIZE];
static {
for (int i = 0; i < POOL_MAX_LENGTH; i++) {
for (int i = 0; i < POOL_SIZE; i++) {
bufferGroups[i] = new BufferGroup("buffer_group-" + i);
}
}
public void save(Span span) {
bufferGroups[ThreadLocalRandom.current().nextInt(0, POOL_MAX_LENGTH)].save(span);
bufferGroups[ThreadLocalRandom.current().nextInt(0, POOL_SIZE)].save(span);
}
}