From bd495ab07ea100cefd467b39455dda88d3726a7b Mon Sep 17 00:00:00 2001 From: zhangxin10 Date: Sat, 14 Nov 2015 15:26:16 +0800 Subject: [PATCH] =?UTF-8?q?=E5=8A=A0=E4=B8=8A=E9=94=81?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../cloud/skywalking/sender/DataSenderFactory.java | 12 ++++++++---- 1 file changed, 8 insertions(+), 4 deletions(-) diff --git a/skywalking-api/src/main/java/com/ai/cloud/skywalking/sender/DataSenderFactory.java b/skywalking-api/src/main/java/com/ai/cloud/skywalking/sender/DataSenderFactory.java index b962ed098..d2e27b6d9 100644 --- a/skywalking-api/src/main/java/com/ai/cloud/skywalking/sender/DataSenderFactory.java +++ b/skywalking-api/src/main/java/com/ai/cloud/skywalking/sender/DataSenderFactory.java @@ -97,12 +97,16 @@ public class DataSenderFactory { break; } - try { - availableSenders.add(new DataSender(tmpScoketAddress)); - unUsedSocketAddresses.remove(tmpScoketAddress); - } catch (IOException e) { + synchronized (lock) { + try { + availableSenders.add(new DataSender(tmpScoketAddress)); + unUsedSocketAddresses.remove(tmpScoketAddress); + } catch (IOException e) { + + } } + } try {