java - Guava CacheBuilder移除侦听器

请告诉我我缺少什么。

我在DataPool中有一个由CacheBuilder建立的缓存。 DataPool是一个单例对象，其各种线程可以获取实例并对其执行操作。现在我只有一个线程来产生数据并将其添加到所说的缓存中。

要显示代码的相关部分:

 private InputDataPool(){

    cache=CacheBuilder.newBuilder().expireAfterWrite(1000, TimeUnit.NANOSECONDS).removalListener(
            new RemovalListener(){
                {
                    logger.debug("Removal Listener created");
                }
                                public void onRemoval(RemovalNotification notification) {
                                    System.out.println("Going to remove data from InputDataPool");
                                    logger.info("Following data is being removed:"+notification.getKey());
                                    if(notification.getCause()==RemovalCause.EXPIRED)
                                    {
                                        logger.fatal("This data expired:"+notification.getKey());
                                    }else
                                    {
                                        logger.fatal("This data didn't expired but evacuated intentionally"+notification.getKey());
                                    }

                                }}
                    ).build(new CacheLoader(){

                        @Override
                        public Object load(Object key) throws Exception {
                                logger.info("Following data being loaded"+(Integer)key);
                                Integer uniqueId=(Integer)key;
                                return InputDataPool.getInstance().getAndRemoveDataFromPool(uniqueId);

                        }

                    });
}

public static InputDataPool getInstance(){
        if(clsInputDataPool==null){
            synchronized(InputDataPool.class){
                if(clsInputDataPool==null)
                {
                    clsInputDataPool=new InputDataPool();
                }
            }
        }
    return clsInputDataPool;
}

从所述线程进行的调用非常简单

 while(true){
 inputDataPool.insertDataIntoPool(inputDataPacket);
     //call some logic which comes with inputDataPacket and sleep for 2 seconds.
}

而inputDataPool.insertDataIntoPool就像

inputDataPool.insertDataIntoPool(InputDataPacket inputDataPacket){
 cache.get(inputDataPacket.getId());
}

现在的问题是，缓存中的元素应该在1000纳秒后过期，因此当第二次调用inputDataPool.insertDataIntoPool时，第一次插入的数据将被撤出，因为在调用之后必须已经过期插入2秒钟后，应调用相应的Removal Listener。
但是，这没有发生。我调查了缓存统计信息，无论调用cache.get(id)多少时间，evictionCount始终为零。

但重要的是，如果我扩展inputDataPool.insertDataIntoPool

  inputDataPool.insertDataIntoPool(InputDataPacket inputDataPacket){
 cache.get(inputDataPacket.getId());
    try{
     Thread.sleep(2000);
   }catch(InterruptedException ex){ex.printStackTrace();
     }
cache.get(inputDataPacket.getId())
}

然后驱逐将按预期进行，并调用移除监听器。

现在，我很茫然，现在我缺少一些可以期待这种行为的东西。请帮我看看。

附言请忽略任何错别字。也不会进行检查，也不会使用任何泛型，所有这些都只是在测试CacheBuilder功能的阶段。

谢谢

最佳答案

如javadoc和user guide中所述，没有线程可以确保在延迟过去后立即从缓存中删除条目。取而代之的是，如果写操作很少，则在写操作期间删除条目，有时在读操作期间删除条目。这是为了实现高吞吐量和低延迟。当然，每个写操作都不会导致清除:

使用CacheBuilder构建的缓存不执行清除和逐出值
“自动”或值过期后立即进行，或
排序。相反，它会在执行期间进行少量维护
写操作，或者在偶尔的读操作期间(如果写操作)
罕见。

这样做的原因如下:如果我们要执行Cache
持续维护，我们需要创建一个线程，
操作将与用户操作争夺共享锁。
此外，某些环境会限制线程的创建，
这会使CacheBuilder在该环境中无法使用。