Java 8はサプライヤのサポートをキャッシュしていますか？

Question

guavaライブラリには、Java 8を拡張しない独自のSupplierがあります。Supplier。また、guavaはサプライヤのキャッシュを提供します（Suppliers#memoize）。

は似たものはありますが、Java 8のサプライヤーのために？

Answer 1

ありが全く組み込まれていない-でのJava機能メモ化のために、それはそれを実装するのは非常に難しいことではありませんが、例えば、次のように：

public static <T> Supplier<T> memoize(Supplier<T> delegate) { 
    AtomicReference<T> value = new AtomicReference<>(); 
    return() -> { 
     T val = value.get(); 
     if (val == null) { 
      val = value.updateAndGet(cur -> cur == null ? 
        Objects.requireNonNull(delegate.get()) : cur); 
     } 
     return val; 
    }; 
} 

注異なる実装のアプローチが存在すること。上記の実装は、メモを取られたサプライヤが異なるスレッドから同時に複数回要求した場合に、デリゲートを数回呼び出すことがあります。時には、そのような実装がロック付きの明示的な同期よりも優先されることもあります。ロックが好まれている場合は、DCLを使用することができる：

public static <T> Supplier<T> memoizeLock(Supplier<T> delegate) { 
    AtomicReference<T> value = new AtomicReference<>(); 
    return() -> { 
     T val = value.get(); 
     if (val == null) { 
      synchronized(value) { 
       val = value.get(); 
       if (val == null) { 
        val = Objects.requireNonNull(delegate.get()); 
        value.set(val); 
       } 
      } 
     } 
     return val; 
    }; 
} 

をまた@LouisWassermanが正しくコメントで述べたように、あなたは簡単にメソッド参照を使用してグアバサプライヤー、その逆にJDKのサプライヤーを変換することができ、注意してください。

java.util.function.Supplier<String> jdkSupplier =() -> "test"; 
com.google.common.base.Supplier<String> guavaSupplier = jdkSupplier::get; 
java.util.function.Supplier<String> jdkSupplierBack = guavaSupplier::get; 

したがって、Guava関数とJDK関数を切り替えるのは大きな問題ではありません。

Answer 2

最も簡単な解決策は、最も簡単なのは常に最も効率的ではありません、しかし、

public static <T> Supplier<T> memoize(Supplier<T> original) { 
    ConcurrentHashMap<Object, T> store=new ConcurrentHashMap<>(); 
    return()->store.computeIfAbsent("dummy", key->original.get()); 
} 

だろう。

あなたはクリーンで効率的なソリューションをしたい場合は、変更可能な状態を保持するために匿名の内部クラスに頼ることは報われる：

public static <T> Supplier<T> memoize1(Supplier<T> original) { 
    return new Supplier<T>() { 
     Supplier<T> delegate = this::firstTime; 
     boolean initialized; 
     public T get() { 
      return delegate.get(); 
     } 
     private synchronized T firstTime() { 
      if(!initialized) { 
       T value=original.get(); 
       delegate=() -> value; 
       initialized=true; 
      } 
      return delegate.get(); 
     } 
    }; 
} 

をこれが初めて操作を行い、その後になるデリゲートのサプライヤーを使用して、取得された最初の評価の結果を無条件に返すサプライヤと置き換えます。それはfinalのフィールドセマンティクスを持っているので、追加の同期化なしで無条件に返すことができます。​​方法firstTime()インサイド

、デリゲートが交換される前に、初期化時の同時アクセスの場合には、複数のスレッドがメソッドのエントリで待機可能性があるため、必要に応じinitializedフラグが依然として存在しています。したがって、これらのスレッドは初期化が既に完了したことを検出する必要があります。その後のすべてのアクセスでは、新しいデリゲートサプライヤが読み込まれ、値がすぐに取得されます。

正確