3

どこが足りないのか教えてください。

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回呼び出されると、最初に挿入されたデータは、呼び出しが終わった後に期限切れになっている必要があるため、退避されます。挿入から2秒後、それに応じて削除リスナーを呼び出す必要があります。しかし、これは起こっていません。キャッシュの統計を調べたところ、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())
}

次に、削除リスナーが呼び出された状態で、期待どおりに削除が行われます。

今、私はそのような行動を期待する何かを逃している瞬間に非常に無知です。あなたが何かを見たら、私が見るのを手伝ってください。

PSタイプミスは無視してください。また、これはCacheBuilder機能のテスト段階にあるため、チェックは行われず、ジェネリックは使用されていません。

ありがとう

4

2 に答える 2

10

javadoc およびユーザー ガイドで説明されているように、遅延が経過するとすぐにエントリがキャッシュから削除されることを確認するスレッドはありません。代わりに、エントリは書き込み操作中に削除され、書き込みがまれな場合は読み取り操作中に削除されることがあります。これは、高スループットと低レイテンシーを可能にするためです。もちろん、すべての書き込み操作でクリーンアップが発生するわけではありません。

CacheBuilder で構築されたキャッシュは、クリーンアップを実行せず、値を「自動的に」削除したり、値の有効期限が切れた直後に削除したり、そのようなものを削除したりしません。代わりに、書き込み操作中、または書き込みがまれな場合は時折の読み取り操作中に少量のメンテナンスを実行します。

その理由は次のとおりです。キャッシュのメンテナンスを継続的に実行したい場合、スレッドを作成する必要があり、その操作は共有ロックのユーザー操作と競合します。さらに、一部の環境ではスレッドの作成が制限されているため、その環境では CacheBuilder が使用できなくなります。

于 2012-05-16T22:16:04.793 に答える
1

私は同じ問題を抱えていましたが、これは 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);

                        }

                    });

この問題は解決されます。それは一種の有線ですが、私はそれが何であるかを推測します:)

于 2016-01-08T16:00:16.480 に答える