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

1.加上了server线程的名称，以及线程序列号。

This commit is contained in:
wusheng 2016-02-17 11:32:22 +08:00
parent 280787d51d
commit 4e7c931af4
5 changed files with 13 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
skywalking-server/src/main/java/com/ai/cloud/skywalking/reciever/buffer/AppendEOFFlagThread.java
View File

@ -14,6 +14,7 @@ class AppendEOFFlagThread extends Thread {
private File[] dataBufferFiles;
public AppendEOFFlagThread(File[] dataBufferFiles) {
super("AppendEOFFlagThread");
this.dataBufferFiles = dataBufferFiles;
}

4
skywalking-server/src/main/java/com/ai/cloud/skywalking/reciever/buffer/DataBufferThread.java
View File

@ -23,8 +23,8 @@ public class DataBufferThread extends Thread {
private FileOutputStream outputStream;
private AtomicInteger index = new AtomicInteger();
public DataBufferThread() {
super("DataBufferThread");
public DataBufferThread(int threadIdx) {
super("DataBufferThread_" + threadIdx);
try {
file = new File(DATA_BUFFER_FILE_PARENT_DIRECTORY, getFileName());
if (file.exists()) {

14
skywalking-server/src/main/java/com/ai/cloud/skywalking/reciever/buffer/DataBufferThreadContainer.java
View File

@ -1,10 +1,6 @@
package com.ai.cloud.skywalking.reciever.buffer;
import com.ai.cloud.skywalking.reciever.conf.Config;
import org.apache.commons.io.FileUtils;
import org.apache.commons.io.comparator.NameFileComparator;
import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;
import static com.ai.cloud.skywalking.reciever.conf.Config.Persistence.MAX_APPEND_EOF_FLAGS_THREAD_NUMBER;
import java.io.File;
import java.util.ArrayList;
@ -12,7 +8,11 @@ import java.util.Arrays;
import java.util.List;
import java.util.concurrent.ThreadLocalRandom;
import static com.ai.cloud.skywalking.reciever.conf.Config.Persistence.MAX_APPEND_EOF_FLAGS_THREAD_NUMBER;
import org.apache.commons.io.comparator.NameFileComparator;
import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;
import com.ai.cloud.skywalking.reciever.conf.Config;
public class DataBufferThreadContainer {
@ -57,7 +57,7 @@ public class DataBufferThreadContainer {
logger.info("Data buffer thread size {} begin to init ", Config.Server.
MAX_DEAL_DATA_THREAD_NUMBER);
for (int i = 0; i < Config.Server.MAX_DEAL_DATA_THREAD_NUMBER; i++) {
DataBufferThread dataBufferThread = new DataBufferThread();
DataBufferThread dataBufferThread = new DataBufferThread(i);
dataBufferThread.start();
buffers.add(dataBufferThread);
}

4
skywalking-server/src/main/java/com/ai/cloud/skywalking/reciever/persistance/PersistenceThread.java
View File

@ -17,8 +17,8 @@ public class PersistenceThread extends Thread {
private Logger logger = LogManager.getLogger(PersistenceThread.class);
PersistenceThread() {
super("PersistenceThread");
PersistenceThread(int threadIdx) {
super("PersistenceThread_" + threadIdx);
}
@Override

2
skywalking-server/src/main/java/com/ai/cloud/skywalking/reciever/persistance/PersistenceThreadLauncher.java
View File

@ -7,7 +7,7 @@ public class PersistenceThreadLauncher {
public static void doLaunch() {
new RegisterPersistenceThread().start();
for (int i = 0; i < Config.Server.MAX_DEAL_DATA_THREAD_NUMBER; i++) {
new PersistenceThread().start();
new PersistenceThread(i).start();
}
}
}