home/pinpoint
2
0
Fork 0
mirror of https://github.com/wahyd4/pinpoint.git synced 2026-08-18 17:26:14 +10:00
Code Issues Packages Projects Releases Wiki Activity

[강운덕] [LUCYSUS-1744] testweb의 aucusclient 를 dispose하도록 변경.

Browse Source 
git-svn-id: http://svn.bds.nhncorp.com/pe/hippo-server/trunk@946 84d0f5b1-2673-498c-a247-62c4ff18d310
This commit is contained in:
Woonduk Kang
2012-11-28 10:28:26 +00:00
parent f443d0f5e7
commit b2edec92b2
1 changed files with 22 additions and 23 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/main/java/com/profiler/server/receiver/udp/MultiplexedUDPReceiver.java
+22 -23
View File
@@ -5,10 +5,7 @@ import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.SocketException;
import java.net.SocketTimeoutException;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.RejectedExecutionException;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.*;
import java.util.concurrent.atomic.AtomicBoolean;
import com.profiler.server.config.TomcatProfilerReceiverConfig;
@@ -18,17 +15,17 @@ import org.springframework.context.support.GenericApplicationContext;
public class MultiplexedUDPReceiver implements DataReceiver {
private static final int AcceptedSize = 65507;
private static final int AcceptedSize = 65507;
private final Logger logger = LoggerFactory.getLogger(this.getClass().getName());
private final ExecutorService worker = Executors.newFixedThreadPool(1024);
private final Logger logger = LoggerFactory.getLogger(this.getClass().getName());
private final ThreadPoolExecutor worker = (ThreadPoolExecutor) Executors.newFixedThreadPool(512);
private DatagramSocket socket = null;
private DatagramSocket socket = null;
private GenericApplicationContext context;
private MultiplexedPacketHandler multiplexedPacketHandler;
long rejectedExecutionCount = 0;
long rejectedExecutionCount = 0;
private AtomicBoolean state = new AtomicBoolean(true);
@@ -39,13 +36,13 @@ public class MultiplexedUDPReceiver implements DataReceiver {
}
private Thread ioThread = new Thread(MultiplexedUDPReceiver.class.getSimpleName()) {
@Override
public void run() {
receive();
}
};
@Override
public void run() {
receive();
}
};
public void receive() {
public void receive() {
if (logger.isInfoEnabled()) {
logger.info("Waiting for " + MultiplexedUDPReceiver.class.getSimpleName());
}
@@ -74,7 +71,9 @@ public class MultiplexedUDPReceiver implements DataReceiver {
}
continue;
}
if (logger.isDebugEnabled()) {
logger.debug("pool getActiveCount:{}", worker.getActiveCount());
}
try {
worker.execute(new DispatchPacket(packet));
} catch (RejectedExecutionException ree) {
@@ -85,7 +84,7 @@ public class MultiplexedUDPReceiver implements DataReceiver {
}
}
}
}
}
private DatagramSocket createSocket() {
try {
@@ -98,18 +97,18 @@ public class MultiplexedUDPReceiver implements DataReceiver {
}
@Override
public void start() {
public void start() {
if (socket != null) {
this.ioThread.start();
logger.info("UDP Packet reader started.");
} else {
throw new RuntimeException("socket create fail");
}
}
}
@Override
public void shutdown() {
logger.info("Shutting down UDP Packet reader.");
@Override
public void shutdown() {
logger.info("Shutting down UDP Packet reader.");
state.set(false);
// 그냥 닫으면 되는건지?
socket.close();
@@ -120,7 +119,7 @@ public class MultiplexedUDPReceiver implements DataReceiver {
Thread.currentThread().interrupt();
}
}
}
private class DispatchPacket implements Runnable {