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 {