SRSoftware/Umbrella
1
0
Fork 0
Code Issues Pull Requests Actions Projects Releases Wiki Activity

trying to circumvent the ConcurrentModificaationException thrown when pushing new messages

Browse Source 
Signed-off-by: Stephan Richter <s.richter@srsoftware.de>
This commit is contained in:
Stephan Richter
2026-01-27 11:24:26 +01:00
parent e113d6389a
commit 6cab16b5bb
1 changed files with 3 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
bus/src/main/java/de/srsoftware/umbrella/messagebus/MessageBus.java
View File

@@ -3,6 +3,8 @@ package de.srsoftware.umbrella.messagebus;
import de.srsoftware.umbrella.messagebus.events.Event; import de.srsoftware.umbrella.messagebus.events.Event;
import java.util.HashSet; import java.util.HashSet;
import java.util.List;
import java.util.Map;
import java.util.Set; import java.util.Set;
public class MessageBus { public class MessageBus {
@@ -15,7 +17,7 @@ public class MessageBus {
new Thread(() -> { // TODO: use thread pool new Thread(() -> { // TODO: use thread pool
try { try {
Thread.sleep(100); Thread.sleep(100);
listeners.parallelStream().forEach(l -> l.onEvent(event)); List.copyOf(listeners).parallelStream().forEach(l -> l.onEvent(event));
} catch (InterruptedException ignored) { } catch (InterruptedException ignored) {
} }
}).start(); }).start();