From e839bd85ed60b52cb85effe000c91beac18050ae Mon Sep 17 00:00:00 2001 From: koo-taejin Date: Thu, 14 Aug 2014 14:21:57 +0900 Subject: [PATCH] =?UTF-8?q?#2=20PinpointSocket=20=EA=B5=AC=ED=98=84?= =?UTF-8?q?=EC=B2=B4=EC=97=90=20ReconnectEvenetListener=EB=A5=BC=20?= =?UTF-8?q?=EB=93=B1=EB=A1=9D?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit 데이터 콜렉션 객체 변경 (arralist -> copyonwritearraylist) --- .../pinpoint/rpc/client/PinpointSocket.java | 20 ++++++------------- 1 file changed, 6 insertions(+), 14 deletions(-) diff --git a/src/main/java/com/nhn/pinpoint/rpc/client/PinpointSocket.java b/src/main/java/com/nhn/pinpoint/rpc/client/PinpointSocket.java index c614e6761..b2c646d53 100644 --- a/src/main/java/com/nhn/pinpoint/rpc/client/PinpointSocket.java +++ b/src/main/java/com/nhn/pinpoint/rpc/client/PinpointSocket.java @@ -2,6 +2,7 @@ package com.nhn.pinpoint.rpc.client; import java.util.ArrayList; import java.util.List; +import java.util.concurrent.CopyOnWriteArrayList; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -26,7 +27,7 @@ public class PinpointSocket { private volatile boolean closed; - private List reconnectEventListeners = new ArrayList(); + private List reconnectEventListeners = new CopyOnWriteArrayList(); public PinpointSocket() { this(new ReconnectStateSocketHandler()); @@ -81,28 +82,19 @@ public class PinpointSocket { return false; } - synchronized (this) { - return this.reconnectEventListeners.add(eventListener); - } + return this.reconnectEventListeners.add(eventListener); } public boolean removePinpointSocketReconnectEventListener(PinpointSocketReconnectEventListener eventListener) { if (eventListener == null) { return false; } - synchronized (this) { - return this.reconnectEventListeners.remove(eventListener); - } + + return this.reconnectEventListeners.remove(eventListener); } private List getPinpointSocketReconnectEventListener() { - List result = new ArrayList(); - synchronized (this) { - for (PinpointSocketReconnectEventListener eventListener : this.reconnectEventListeners) { - result.add(eventListener); - } - } - + List result = new ArrayList(reconnectEventListeners); return result; }