Commit 8d2ad022086d4fba5012721bf6717488f9c0b5c6
1 parent
000bbad2
替换线程不安全的map
Showing
1 changed file
with
2 additions
and
1 deletions
src/main/java/com/genersoft/iot/vmp/gb28181/transmit/callback/DeferredResultHolder.java
| @@ -2,6 +2,7 @@ package com.genersoft.iot.vmp.gb28181.transmit.callback; | @@ -2,6 +2,7 @@ package com.genersoft.iot.vmp.gb28181.transmit.callback; | ||
| 2 | 2 | ||
| 3 | import java.util.HashMap; | 3 | import java.util.HashMap; |
| 4 | import java.util.Map; | 4 | import java.util.Map; |
| 5 | +import java.util.concurrent.ConcurrentHashMap; | ||
| 5 | 6 | ||
| 6 | import org.springframework.http.HttpStatus; | 7 | import org.springframework.http.HttpStatus; |
| 7 | import org.springframework.http.ResponseEntity; | 8 | import org.springframework.http.ResponseEntity; |
| @@ -24,7 +25,7 @@ public class DeferredResultHolder { | @@ -24,7 +25,7 @@ public class DeferredResultHolder { | ||
| 24 | 25 | ||
| 25 | public static final String CALLBACK_CMD_PlAY = "CALLBACK_PLAY"; | 26 | public static final String CALLBACK_CMD_PlAY = "CALLBACK_PLAY"; |
| 26 | 27 | ||
| 27 | - private Map<String, DeferredResult> map = new HashMap<String, DeferredResult>(); | 28 | + private Map<String, DeferredResult> map = new ConcurrentHashMap<String, DeferredResult>(); |
| 28 | 29 | ||
| 29 | public void put(String key, DeferredResult result) { | 30 | public void put(String key, DeferredResult result) { |
| 30 | map.put(key, result); | 31 | map.put(key, result); |