java - 如何在不同的线程中运行监听器或在不同的线程中进行计算

Question

我正在尝试使用 Google Guava 构建缓存，并想对过期对象进行一些计算。如果删除了某个对象，removalListener 会通知我。

我如何在与主应用程序不同的线程中运行 removalListener，或者将过期对象(在下面的简单示例中为 Integer 3)传递给处理计算的不同线程？

编辑:由于计算时间很短，但经常发生，我宁愿不是每次都创建一个新线程(将是数千个线程)，而是让一个(或两个)计算所有对象。

简单的例子:

Cache<String, Integer> cache = CacheBuilder.newBuilder().maximumSize(100)
        .expireAfterAccess(100, TimeUnit.NANOSECONDS)
        .removalListener(new RemovalListener<String, Integer>() {
            public void onRemoval(final RemovalNotification notification) {
                if (notification.getCause() == RemovalCause.EXPIRED) {
                    System.out.println("removed " + notification.getValue());
                    // do calculation=> this should be in another thread
                }
            }
        })
        .build();
 cache.put("test1", 3);
 cache.cleanUp();

Answer 1

要在执行程序中运行您的监听器，请用 RemovalListeners.asynchronous 包装它.

.removalListener(异步(new RemovalListener() { ... }, 执行器))