Java接收API不规则返回键值对，如何在HashMap匹配条件时触发代码

你当前的代码存在两个核心问题：

• requestHashMapUpdate是异步调用，API会在独立线程中执行回调更新HashMap，主线程调用后立刻做条件判断，此时回调大概率还没返回数据，所以判断直接不通过就执行完毕
• 原生HashMap不是线程安全的，多线程环境下读写会存在可见性问题，就算回调更新了值，主线程也可能读取到旧值，还有概率触发并发修改异常

核心思路是不做主动轮询，每次API回调更新数据时主动检查目标条件，满足后通知主线程执行后续代码，完全适配不规则的返回间隔，实时性最高。

改造步骤 #

1. 线程安全改造 #

将ClientAPI中的HashMap替换为ConcurrentHashMap，保证多线程读写的原子性和可见性。

2. 新增条件等待机制 #

用CompletableFuture实现等待信号，每次更新键值对时检查是否满足目标条件，满足就完成Future唤醒等待线程。

完整可运行代码 #

ClientAPI类改造 #

import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.CompletableFuture;

class ClientAPI{
    private ConcurrentHashMap<String,Integer> myHashMap;
    // 用于等待key1=1的信号
    private CompletableFuture<Void> key1MatchFuture = new CompletableFuture<>();
    
    // 修正原代码构造方法名大小写错误
    public ClientAPI(){
        myHashMap = new ConcurrentHashMap<>();
    }

    // API回调更新方法
    public void updateHashMapKeyValuePair(String key, int value){
        System.out.println("Key:" + key + ", Value: " + value);
        myHashMap.put(key,value);
        // 每次更新后检查目标条件，满足则触发信号
        if("key1".equals(key) && value == 1){
            key1MatchFuture.complete(null);
        }
    }

    public ConcurrentHashMap<String,Integer> getMyHashMap(){
        return myHashMap;
    }

    // 新增等待条件满足的方法
    public void waitForKey1Match() throws InterruptedException {
        try {
            key1MatchFuture.get();
        } catch (Exception e) {
            Thread.currentThread().interrupt();
            throw new RuntimeException("等待中断", e);
        }
    }

    // 补全原代码缺失的API方法
    public void connect() {
        // 实际API连接逻辑
    }
    public void requestHashMapUpdate() {
        // 模拟API异步请求逻辑，实际由API内部实现
        new Thread(() -> {
            try {
                // 模拟1-5秒的不规则返回间隔
                Thread.sleep((long) (Math.random() * 4000 + 1000));
                updateHashMapKeyValuePair("key1", 1);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }).start();
    }
}

主类改造 #

class Testing{
    public static void main(String[] args) throws InterruptedException {
        ClientAPI clientAPI = new ClientAPI();
        clientAPI.connect();
        clientAPI.requestHashMapUpdate();

        // 阻塞等待条件满足，无轮询开销，条件满足立刻唤醒执行
        clientAPI.waitForKey1Match();
        
        // 目标代码
        System.out.println("Print Me only if key and value are matched !!!!!!!!");
    }
}

方案优势 #

• 无轮询CPU开销：只有键值对更新时才会检查条件，不会空转浪费资源
• 实时性高：条件满足后立刻触发后续代码，无额外延迟
• 适配任意返回间隔：不需要预设等待时间，完全适配API不规则的返回特性
• 线程安全：ConcurrentHashMap彻底避免并发读写的各类问题

如果需要支持多个不同的键值对等待需求，可以把单个CompletableFuture替换为存储条件和Future映射的Map，灵活扩展即可。

内容的提问来源于stack exchange，提问作者user1769197