diff options
Diffstat (limited to 'stage1/ClassLoaderCache.scala')
-rw-r--r-- | stage1/ClassLoaderCache.scala | 44 |
1 files changed, 0 insertions, 44 deletions
diff --git a/stage1/ClassLoaderCache.scala b/stage1/ClassLoaderCache.scala index d303da3..3e77dd6 100644 --- a/stage1/ClassLoaderCache.scala +++ b/stage1/ClassLoaderCache.scala @@ -15,47 +15,3 @@ class ClassLoaderCache(logger: Logger){ Some(logger) ) } - -private[cbt] class LockableKey -/** -A cache that lazily computes values if needed during lookup. -Locking occurs on the key, so separate keys can be looked up -simultaneously without a deadlock. -*/ -final private[cbt] class KeyLockedLazyCache[Key <: AnyRef,Value <: AnyRef]( - val keys: ConcurrentHashMap[Key,AnyRef], - val values: ConcurrentHashMap[AnyRef,Value], - logger: Option[Logger] -){ - def get( key: Key, value: => Value ): Value = { - val lockableKey = keys.synchronized{ - if( ! (keys containsKey key) ){ - val lockableKey = new LockableKey - //logger.foreach(_.resolver("CACHE MISS: " ++ key.toString)) - keys.put( key, lockableKey ) - lockableKey - } else { - val lockableKey = keys get key - //logger.foreach(_.resolver("CACHE HIT: " ++ lockableKey.toString ++ " -> " ++ key.toString)) - lockableKey - } - } - import collection.JavaConversions._ - //logger.resolver("CACHE: \n" ++ keys.mkString("\n")) - // synchronizing on key only, so asking for a particular key does - // not block the whole cache, but just that cache entry - key.synchronized{ - if( ! (values containsKey lockableKey) ){ - values.put( lockableKey, value ) - } - values get lockableKey - } - } - def remove( key: Key ) = keys.synchronized{ - assert(keys containsKey key) - val lockableKey = keys get key - keys.remove( key ) - assert(values containsKey lockableKey) - values.remove( lockableKey ) - } -} |