如何聆听Hashmap的更改Java中的特定键的值

Question

我必须等到 HashMap 键的值从另一个线程更改，然后必须继续请求处理。

Answer 1

我认为最灵活的解决方案是实现观察者模式。

注意 build-inn Interfaces 观察者和可观察自JDK版本9都被弃用。即使您正在使用Java 8不要使用它们。他们的问题是他们的名称以及observer的方法 不向代码的读者讲任何事件的内容触发以及可能采取什么样的动作。

从图中可以看到屁股，主题应包含观察者的收集 （或侦听器）。

在您的情况下，应该集体包含hashmap您要收听的更新。不要延长地图，而是用班级包装。因为如果您选择扩展hashmap您的代码将取决于其实现。例如，hashmap的任何更改，例如，添加了新方法或改进了现有方法，都可能破坏您的代码（ 本主题在Joshua blochtake的“有效Java”一书中介绍，请有一个查看更多信息）。

因此，假设我们有一个类OrderManager维护Order s的地图。此类将是A 主题 。

添加了几个服务，例如BillingManager，LoggingManager ，也许还需要更多需要通知新订单的服务。这些是我们的***观察者***。所有这些类是接口，假设 orderaddedlistener 定义单个方法 onorderAdded（订单订单）``这就是我们感兴趣的事件。

note ，如果您需要收听其他事件，例如删除或更新，则需要用一个针对每个目标事件的方法定义一个新界面，因为接口隔离原则建议。

order> ordersmanager >必须有一个观察者的集合。当添加新订单时，主题通过观察者的收集和调用OnorderAdded（）方法进行迭代。

为了添加一个观察者，需要收听订单添加的事件ordermanager必须定义一种注册它的方法，也是添加另一个以登记已注册的观察者的好习惯当您不再需要时，可以将其删除。

异步处理

注意，在此示例中，事件正在相同的线程中进行处理。如果观察者执行的操作是昂贵的或可能会阻止线程，则为了异步发射它们，您可以创建一个可以实现运行的类，并保留对 observer 和<的参考。 em> event （订购添加/更新），方法run（）将触发观察者。当发生新事件时，ordermanager而不是在每个观察者上调用onorderadded（）应创建一个通过传递观察者和a 新订单 对其构造函数，然后创建和启动新线程。

这是一种简化的方法。但是我想这将使人们对总体想法有所了解。

实现示例

表明：

public class OrderManager {
    private Map<Long, Order> orderById = new HashMap<>();
    private Set<OrderAddedListener> listeners = new HashSet<>();
    
    public void addOrder(Order order) {
        // notifying observers
        listeners.forEach(observer -> observer.onOrderAdded(order));
        
        orderById.put(order.getId(), order);
    }
    
    // more methods like removeOrder(), getOrderCount() etc.
    
    public boolean registerOrderAddedListener(OrderAddedListener listener) {
        return listeners.add(listener);
    }
    
    public boolean unregisterOrderAddedListener(OrderAddedListener listener) {
        return listeners.remove(listener);
    }
}

public interface OrderAddedListener {
    void onOrderAdded(Order order);
}

public class LoggingManager implements OrderAddedListener {
    private Logger logger;
    
    @Override
    public void onOrderAdded(Order order) {
//        logger.log();
        System.out.println("Log message has been written");
    }
}

public class BillingManager implements OrderAddedListener {
    private BillingService billingService;
    
    @Override
    public void onOrderAdded(Order order) {
//        billingService.sendBill(order);
        System.out.println("A bill has been sent");
    }
}

main（） - 一个简单的演示

public static void main(String[] args) {
    OrderManager orderManager = new OrderManager();
    orderManager.registerOrderAddedListener(new LoggingManager());
    orderManager.registerOrderAddedListener(new BillingManager());
    orderManager.addOrder(new Order());
}

输出

A log message has been written
A bill has been sent