aboutsummaryrefslogtreecommitdiff
path: root/stage1/ClassLoaderCache.scala
diff options
context:
space:
mode:
Diffstat (limited to 'stage1/ClassLoaderCache.scala')
-rw-r--r--stage1/ClassLoaderCache.scala44
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 )
- }
-}