fix(core): redundant synchronization on the FlowListeners

kestra-io · Jun 5, 2023 · 8d56a96 · 8d56a96
1 parent 227a161
commit 8d56a96
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/core/src/main/java/io/kestra/core/runners/FlowListeners.java b/core/src/main/java/io/kestra/core/runners/FlowListeners.java
@@ -103,7 +103,7 @@ private boolean remove(Flow flow) {
         }
     }
 
-    private synchronized void upsert(Flow flow) {
+    private void upsert(Flow flow) {
         synchronized (this) {
             this.remove(flow);
 
@@ -126,7 +126,7 @@ private void notifyConsumersEach(Flow flow, Flow previous) {
     }
 
     @Override
-    public synchronized void listen(Consumer<List<Flow>> consumer) {
+    public void listen(Consumer<List<Flow>> consumer) {
         synchronized (this) {
             consumers.add(consumer);
             consumer.accept(new ArrayList<>(this.flows()));