Examples of BlockingCache

net.sf.cache4j.impl.BlockingCache
new Exception(ce); } if (person != null) { return person; } try { person = loadPersonFromDb(id); } catch (Exception e) { //throw new Exception(e); } finally { try { _personCache.put(id, person); } catch (CacheException ce) { //throw new Exception(ce); } } �� :
```
 Person person = ... ; Long id = person.getId(); removePersonFromDb(id); try { _personCache.remove(id); } catch (CacheException ce) { //throw new Exception(ce); } 
```
@version $Revision: 1.0 $ $Date:$ @author Yuriy Stepovoy. stepovoy@gmail.com
net.sf.ehcache.constructs.blocking.BlockingCache
A blocking decorator for an Ehcache, backed by a {@link Ehcache}.
It allows concurrent read access to elements already in the cache. If the element is null, other reads will block until an element with the same key is put into the cache.
This is useful for constructing read-through or self-populating caches.
This implementation uses the {@link Mutex} class from Doug Lea's concurrency package. If you wish to usethis class, you will need the concurrent package in your class path.
It features:
- Excellent liveness.
- Fine-grained locking on each element, rather than the cache as a whole.
- Scalability to a large number of threads.
This class has been updated to use Lock striping. The Mutex implementation gives scalability but creates many Mutex objects of 24 bytes each. Lock striping limits their number to 100.
A version of this class is planned which will dynamically use JDK5's concurrency package, which is based on Doug Lea's, so as to avoid a dependency on his package for JDK5 systems. This will not be implemented until JDK5 is released on MacOSX and Linux, as JDK5 will be required to compile it, though any version from JDK1.2 up will be able to run the code, falling back to Doug Lea's concurrency package, if the JDK5 package is not found in the classpath.
The Mutex class does not appear in the JDK5 concurrency package. Doug Lea has generously offered the following advice:
"You should just be able to use ReentrantLock here. We supply ReentrantLock, but not Mutex because the number of cases where a non-reentrant mutex is preferable is small, and most people are more familiar with reentrant seamantics. If you really need a non-reentrant one, the javadocs for class AbstractQueuedSynchronizer include sample code for them."
-Doug
"Hashtable / synchronizedMap uses the "one big fat lock" approach to guard the mutable state of the map. That works, but is a big concurrency bottleneck, as you've observed. You went to the opposite extreme, one lock per key. That works (as long as you've got sufficient synchronization in the cache itself to protect its own data structures.)
Lock striping is a middle ground, partitioning keys into a fixed number of subsets, like the trick used at large theaters for will-call ticket pickup -- there are separate lines for "A-F, G-M, N-R, and S-Z". This way, there are a fixed number of locks, each guarding (hopefully) 1/Nth of the keys." - Brian Goetz
Further improvements to hashing suggested by Joe Bowbeer. @author Greg Luck @version $Id: BlockingCache.java 796 2008-10-09 02:39:03Z gregluck $
org.apache.ibatis.cache.decorators.BlockingCache
Simple blocking decorator Sipmle and inefficient version of EhCache's BlockingCache decorator. It sets a lock over a cache key when the element is not found in cache. This way, other threads will wait until this element is filled instead of hitting the database. @author Eduardo Macarron

Examples of net.sf.ehcache.constructs.blocking.BlockingCache


  public static <T extends Nameable> void updateCaches(CacheManager cacheManager, T obj, Class<T> cacheClass) {
    Cache cache = DbUtils.lookupCache(cacheManager, cacheClass, true);
    if (cache != null && cache.getKeys().size() > 0) {
      log.debug("Removing " + cacheClass.getSimpleName() + " " + obj.getId() + " from " + cache.getName());
      BlockingCache c = new BlockingCache(cache);
      c.remove(DbUtils.hashCodeCacheKeyFor(obj.getId()));
    }


    cache = DbUtils.lookupCache(cacheManager, cacheClass, false);
    if (cache != null && cache.getKeys().size() > 0) {
      log.debug("Removing " + cacheClass.getSimpleName() + " " + obj.getId() + " from " + cache.getName());
      BlockingCache c = new BlockingCache(cache);
      c.remove(DbUtils.hashCodeCacheKeyFor(obj.getId()));
    }
  }

View Full Code Here

Examples of net.sf.ehcache.constructs.blocking.BlockingCache

    }
  }


  public static <T> void updateListCache(Cache cache, boolean replace, T obj, Class<T> cacheClass) {
    if (cache != null && cache.getKeys().size() > 0) {
      BlockingCache c = new BlockingCache(cache);
      Object cachekey = c.getKeys().get(0);
      List<T> e = (List<T>)c.get(cachekey).getObjectValue();
      if (e.remove(obj)) {
        if (replace) {
          e.add(obj);
        }
      }
      else {
        e.add(obj);
      }
      c.put(new Element(cachekey, e));
    }
  }

View Full Code Here

Examples of net.sf.ehcache.constructs.blocking.BlockingCache

      else {
        return new SelfPopulatingCache(cache, this.cacheEntryFactory);
      }
    }
    if (this.blocking) {
      return new BlockingCache(cache);
    }
    return cache;
  }

View Full Code Here

Examples of net.sf.ehcache.constructs.blocking.BlockingCache

      else {
        return new SelfPopulatingCache(cache, this.cacheEntryFactory);
      }
    }
    if (this.blocking) {
      return new BlockingCache(cache);
    }
    return cache;
  }

View Full Code Here

Examples of net.sf.ehcache.constructs.blocking.BlockingCache

      } else {
        return new SelfPopulatingCache(cache, this.cacheEntryFactory);
      }
    }
    if (this.blocking) {
      return new BlockingCache(cache);
    }
    return cache;
  }

View Full Code Here

Examples of net.sf.ehcache.constructs.blocking.BlockingCache

        if(!cacheManager.cacheExists(cacheName)) {
           cacheManager.addCache(cacheName);
        }


        Ehcache cache = cacheManager.getEhcache(cacheName);
        BlockingCache blockingCache = new BlockingCache(cache);
        blockingCache.setTimeoutMillis(timeout);
        return blockingCache;
    }

View Full Code Here

Examples of net.sf.ehcache.constructs.blocking.BlockingCache

     * 
     * @param cache
     *            a non-null {@link Ehcache}
     */
    public void setCache(Ehcache cache) {
        BlockingCache ref;


        if (!(cache instanceof BlockingCache)) {
            ref = new BlockingCache(cache);
            cache.getCacheManager().replaceCacheWithDecoratedCache(cache, new BlockingCache(cache));
        } else {
            ref = (BlockingCache) cache;
        }


        this.cache = ref;

View Full Code Here

Examples of org.apache.ibatis.cache.decorators.BlockingCache

        cache = new SerializedCache(cache);
      }
      cache = new LoggingCache(cache);
      cache = new SynchronizedCache(cache);
      if (blocking) {
        cache = new BlockingCache(cache);
      }
      return cache;
    } catch (Exception e) {
      throw new CacheException("Error building standard cache decorators.  Cause: " + e, e);
    }

View Full Code Here

0 1 2 3

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.