new CacheLoader<String, String>() {
                  @Override
                  public String load(String key) throws Exception {
                    return cache.get(key2, identityLoader()); // loads a different key, should work
                  }
                }))
        .isEqualTo(key2);
  }

  public void testRecursiveLoad() throws InterruptedException {

                new CacheLoader<String, String>() {
                  @Override
                  public String load(String key) throws Exception {
                    return cache.get(key2, identityLoader()); // loads a different key, should work
                  }
                }))
        .isEqualTo(key2);
  }

  public void testRecursiveLoad() throws InterruptedException {

		}
		duration := max(time.Duration(r.Float64()*float64(time.Minute)),
			// Make sure to sleep at least a second to avoid high CPU ticks.
			time.Second)
		time.Sleep(duration)
	}
}

// Loads bucket replication resync statuses into memory.
func (p *ReplicationPool) loadResync(ctx context.Context, buckets []string, objAPI ObjectLayer) error {
	// Make sure only one node running resync on the cluster.

     */
    ValueReference<K, V> copyFor(
        ReferenceQueue<V> queue, @Nullable V value, ReferenceEntry<K, V> entry);

    /**
     * Notify pending loads that a new value was set. This is only relevant to loading value
     * references.
     */
    void notifyNewValue(@Nullable V newValue);

    /**