поточно-обновление кэшированных ресурса

Question

Логика очень проста:

Foo foo = cache.get(); 
if (isUpToDate(foo)) { 
    return foo; 
} else { 
    foo = getUpdatedFoo(); // slow or expensive 
    cache.put(foo); 
    return foo; 
} 

Однако, я хочу, чтобы убедиться, что

1. только один поток вызывает getUpdatedFoo() в то время
2. если нить A уже звонит getUpdatedFoo(), нить B не назовите его, вместо этого просто ждите нити A's results

Возможно, я смогу собрать что-то, основанное на шаблоне Memoizer от JCiP, но я подозреваю, что есть более простой способ - возможно, с помощью Guava CacheBuilder? Не сразу очевидно, как, однако.

---

Update: Реализована блокировка с двойной проверкой шаблон на FrankPL's answer ниже:

Foo foo = cache.get(); 
if (!isUpToDate(foo)) { 
    lock.lock(); // Will block if some other thread is refreshing 
    try { 
     // See if some other thread already refreshed for us 
     foo = cache.get(); 
     if (!isUpToDate(foo)) { 
      // guess not, we'll refresh it ourselves 
      foo = getUpdatedFoo(); 
      cache.put(foo); 
     } 
    } finally { 
     lock.unlock(); 
    } 
} 
return foo; 

Answer 1

См http://en.wikipedia.org/wiki/Double-checked_locking для двойной блокировки проверил шаблон, который вы могли бы использовать. Вместо new Helper(), используемых в образцах кода, используйте getUpdatedFoo().

Answer 2

Возможно, вы можете рассмотреть блокировку чтения-записи (http://docs.oracle.com/javase/1.5.0/docs/api/java/util/concurrent/locks/ReentrantReadWriteLock.html). Ниже приведен пример кода:

rwlock.readLock().lock(); 
Foo foo = cache.get(); 
if(isUpToDate(foo)) { 
    rwlock.readLock.unlock(); 
    return foo; 
} else { 
    rwlock.readLock.unlock(); 
    rwlock.writeLock.lock(); 
    // recheck if updated 
    Foo foo = cache.get(); 
    if(isUpToDate(foo)) { 
     rwlock.writeLock.unlock(); 
     return foo; 
    } else { 
     foo = getUpdatedFoo(); 
     cache.put(foo); 
     rwlock.writeLock.unlock(); 
     return foo; 
    } 
}