Guava CacheBuilder刪除監聽器

Question

請告訴我我錯在哪裏。

我有一個由CacheBuilder在DataPool內部構建的緩存。 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()) 
} 

然後驅逐發生與去除聽衆被稱爲預期。

現在我非常無能爲力，因爲我錯過了期待這種行爲的東西。如果你看到什麼，請幫我看看。

P.S.請忽略任何輸入錯誤。也沒有進行檢查，沒有使用泛型，因爲這只是測試CacheBuilder功能的階段。

感謝

Answer 1

正如javadoc的解釋，並在user guide，沒有線程確保條目從緩存中一旦延遲過去刪除。相反，在寫入操作期間會刪除條目，偶爾在讀取操作期間如果寫入操作很少。這是爲了實現高吞吐量和低延遲。一個值到期，或 排序後的任何

緩存與CacheBuilder建不進行清理和 驅逐值「自動」或瞬間：當然，每一個寫操作不會導致清理。相反，它在執行 寫入操作期間執行少量維護，或者在偶爾讀取操作期間執行少量維護（如果寫入次數爲 很少）。我們需要創建一個線程，其 操作將與用戶對共享鎖的操作進行競爭。 此外，某些環境會限制線程的創建， 會使CacheBuilder在該環境中無法使用。

Answer 2

我有同樣的問題，我可以在番石榴對CacheBuilder.removalListener

警告文件發現這一點：在調用此方法後，不要繼續使用此緩存 建設者參考;而是使用此方法返回的引用。在 運行時間，這些指向同一個實例，但只有返回的 引用具有正確的通用類型信息，以確保類型安全 。爲獲得最佳效果，請使用上述類文檔中所示的標準方法鏈接成語 ，配置構建器 並在單個語句中構建緩存。如果不注意此建議，可能會導致在將來某個未定義的點處由高速緩存 操作拋出ClassCastException。

所以通過改變代碼中使用，它是將removalListnener後稱爲建設者參考這個問題就可以解決

CacheBuilder builder=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()); 
            } 

           }} 
        ); 
    cache=builder.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); 

         } 

        }); 

這個問題將得到解決。這是一種有線，但我猜這是它是什麼:)