demus/openhab-core
1
0
Fork 0
mirror of https://github.com/danieldemus/openhab-core.git synced 2025-01-11 05:41:52 +01:00
Code Issues 1 Packages Projects Releases Wiki Activity

Fix ConcurrentModificationException in WatchQueueReader (#3016)

Browse Source 
Signed-off-by: Kai Kreuzer <kai@openhab.org>
This commit is contained in:
Kai Kreuzer 2022-06-26 17:14:51 +02:00 committed by GitHub
parent cdeda77322
commit 2cf875fdd8
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
bundles/org.openhab.core/src/main/java/org/openhab/core/service/WatchQueueReader.java
View File

@ -41,6 +41,7 @@ import java.util.List;
import java.util.Map; import java.util.Map;
import java.util.Objects; import java.util.Objects;
import java.util.Set; import java.util.Set;
import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.CopyOnWriteArrayList; import java.util.concurrent.CopyOnWriteArrayList;
import java.util.concurrent.ScheduledExecutorService; import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.ScheduledFuture; import java.util.concurrent.ScheduledFuture;
@ -72,8 +73,8 @@ public class WatchQueueReader implements Runnable {
protected @Nullable WatchService watchService; protected @Nullable WatchService watchService;
private final Map<WatchKey, Path> registeredKeys = new HashMap<>(); private final Map<WatchKey, Path> registeredKeys = new HashMap<>();
private final Map<WatchKey, Set<AbstractWatchService>> keyToService = new HashMap<>(); private final Map<WatchKey, Set<AbstractWatchService>> keyToService = new ConcurrentHashMap<>();
private final Map<AbstractWatchService, Map<Path, byte[]>> hashes = new HashMap<>(); private final Map<AbstractWatchService, Map<Path, byte[]>> hashes = new ConcurrentHashMap<>();
private final List<Notification> notifications = new CopyOnWriteArrayList<>(); private final List<Notification> notifications = new CopyOnWriteArrayList<>();
private @Nullable Thread qr; private @Nullable Thread qr;