Use light collection because of being synchronized already
Change-Id: I206e8a392f8bb158a8de42ef0c536e509fd21433
Showing
1 changed file
with
2 additions
and
2 deletions
... | @@ -67,6 +67,7 @@ import org.slf4j.Logger; | ... | @@ -67,6 +67,7 @@ import org.slf4j.Logger; |
67 | 67 | ||
68 | import java.util.Collections; | 68 | import java.util.Collections; |
69 | import java.util.Dictionary; | 69 | import java.util.Dictionary; |
70 | +import java.util.HashSet; | ||
70 | import java.util.List; | 71 | import java.util.List; |
71 | import java.util.Map; | 72 | import java.util.Map; |
72 | import java.util.Set; | 73 | import java.util.Set; |
... | @@ -599,13 +600,12 @@ public class FlowRuleManager | ... | @@ -599,13 +600,12 @@ public class FlowRuleManager |
599 | private final FlowRuleOperations fops; | 600 | private final FlowRuleOperations fops; |
600 | private final AtomicBoolean hasFailed = new AtomicBoolean(false); | 601 | private final AtomicBoolean hasFailed = new AtomicBoolean(false); |
601 | 602 | ||
602 | - private Set<DeviceId> pendingDevices; | 603 | + private final Set<DeviceId> pendingDevices = new HashSet<>(); |
603 | 604 | ||
604 | FlowOperationsProcessor(FlowRuleOperations ops) { | 605 | FlowOperationsProcessor(FlowRuleOperations ops) { |
605 | this.stages = Lists.newArrayList(ops.stages()); | 606 | this.stages = Lists.newArrayList(ops.stages()); |
606 | this.context = ops.callback(); | 607 | this.context = ops.callback(); |
607 | this.fops = ops; | 608 | this.fops = ops; |
608 | - pendingDevices = Sets.newConcurrentHashSet(); | ||
609 | } | 609 | } |
610 | 610 | ||
611 | @Override | 611 | @Override | ... | ... |
-
Please register or login to post a comment