zhubaomin
5 天以前 531c35275bc1700214ef26442380ad3a80d95838
pipIrr-platform/pipIrr-global/src/main/java/com/dy/pipIrrGlobal/command/ComResultWait.java
New file
@@ -0,0 +1,28 @@
package com.dy.pipIrrGlobal.command;
import java.util.Map;
import java.util.concurrent.CompletableFuture;
import java.util.concurrent.ConcurrentHashMap;
/**
 * @Author: liurunyu
 * @Date: 2025/5/6 16:33
 * @Description
 */
public class ComResultWait {
    //ConcurrentHashMap是线程安全的
    private static final Map<Long, CompletableFuture> features = new ConcurrentHashMap<>();
    public static void put(Long key, CompletableFuture value) {
        features.put(key, value);
    }
    public static CompletableFuture get(Long key) {
        return features.get(key);
    }
    public static void remove(Long key){
        features.remove(key) ;
    }
}