diff options
author | Anton Tananaev <anton.tananaev@gmail.com> | 2016-12-22 07:52:35 +1300 |
---|---|---|
committer | Anton Tananaev <anton.tananaev@gmail.com> | 2016-12-22 06:52:35 +1300 |
commit | 79f3abf6a61220a500e936ffedd7c0d270e9cea4 (patch) | |
tree | bce60b6e37506111b7791187ae5784291d787377 /src/org/traccar/database | |
parent | c5fcf1a6f23c01690ca8643bd3a521ca6509ff75 (diff) | |
download | traccar-server-79f3abf6a61220a500e936ffedd7c0d270e9cea4.tar.gz traccar-server-79f3abf6a61220a500e936ffedd7c0d270e9cea4.tar.bz2 traccar-server-79f3abf6a61220a500e936ffedd7c0d270e9cea4.zip |
Use concurrent maps in connection manager (fix #2723)
Diffstat (limited to 'src/org/traccar/database')
-rw-r--r-- | src/org/traccar/database/ConnectionManager.java | 7 |
1 files changed, 4 insertions, 3 deletions
diff --git a/src/org/traccar/database/ConnectionManager.java b/src/org/traccar/database/ConnectionManager.java index 374e9651d..eb81c9ad9 100644 --- a/src/org/traccar/database/ConnectionManager.java +++ b/src/org/traccar/database/ConnectionManager.java @@ -33,6 +33,7 @@ import java.util.HashMap; import java.util.HashSet; import java.util.Map; import java.util.Set; +import java.util.concurrent.ConcurrentHashMap; import java.util.concurrent.TimeUnit; public class ConnectionManager { @@ -42,9 +43,9 @@ public class ConnectionManager { private final long deviceTimeout; private final boolean enableStatusEvents; - private final Map<Long, ActiveDevice> activeDevices = new HashMap<>(); - private final Map<Long, Set<UpdateListener>> listeners = new HashMap<>(); - private final Map<Long, Timeout> timeouts = new HashMap<>(); + private final Map<Long, ActiveDevice> activeDevices = new ConcurrentHashMap<>(); + private final Map<Long, Set<UpdateListener>> listeners = new ConcurrentHashMap<>(); + private final Map<Long, Timeout> timeouts = new ConcurrentHashMap<>(); public ConnectionManager() { deviceTimeout = Context.getConfig().getLong("status.timeout", DEFAULT_TIMEOUT) * 1000; |