diff --git a/src/main/java/com/profiler/sender/UdpDataSender.java b/src/main/java/com/profiler/sender/UdpDataSender.java index 07cfa5039..bbf0b81b7 100644 --- a/src/main/java/com/profiler/sender/UdpDataSender.java +++ b/src/main/java/com/profiler/sender/UdpDataSender.java @@ -31,7 +31,7 @@ public class UdpDataSender implements DataSender, Runnable { private final LinkedBlockingQueue queue = new LinkedBlockingQueue(1024); - private int maxDrainSize = 10; + private final int maxDrainSize = 10; // 주의 single thread용임. ArrayList보다 더 단순한 오퍼레이션을 수행하는 Collection. private Collection drain = new UnsafeArrayCollection(maxDrainSize); // 주의 single thread용임 @@ -236,7 +236,7 @@ public class UdpDataSender implements DataSender, Runnable { private Collection takeN() { drain.clear(); - int size = queue.drainTo(drain, 10); + int size = queue.drainTo(drain, maxDrainSize); if (size <= 0) { return null; }