【Java开源代码栏目提醒】:文章导读:在新的一年中,各位网友都进入紧张的学习或是工作阶段。网学会员整理了Java开源代码-TransactionalCache.java的相关内容供大家参考,祝大家在新的一年里工作和学习顺利!
//$Id: TransactionalCache.java 6478 2005-04-21 07:57:19Z oneovthafew $
package org.hibernate.cache;
import java.util.Comparator;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
/**
* Support for fully transactional cache implementations like
* JBoss TreeCache. Note that this might be a less scalable
* concurrency strategy than <tt>ReadWriteCache</tt>. This is
* a "synchronous" concurrency strategy.
*
* @author Gavin King
*/
public class TransactionalCache implements CacheConcurrencyStrategy {
private static final Log log = LogFactory.getLog(TransactionalCache.class);
private Cache cache;
public String getRegionName() {
return cache.getRegionName();
}
public Object get(Object key, long txTimestamp) throws CacheException {
if ( log.isDebugEnabled() ) log.debug("cache lookup: " + key);
Object result = cache.read(key);
if ( log.isDebugEnabled() ) {
log.debug( result==null ? "cache miss" : "cache hit" );
}
return result;
}
public boolean put(
Object key,
Object value,
long txTimestamp,
Object version,
Comparator versionComparator,
boolean minimalPut)
throws CacheException {
if ( minimalPut && cache.read(key)!=null ) {
if ( log.isDebugEnabled() ) log.debug("item already cached: " + key);
return false;
}
if ( log.isDebugEnabled() ) log.debug("caching: " + key);
cache.put(key, value);
return true;
}
/**
* Do nothing, returning null.
*/
public SoftLock lock(Object key, Object version) throws CacheException {
//noop
return null;
}
/**
* Do nothing.
*/
public void release(Object key, SoftLock clientLock) throws CacheException {
//noop
}
public boolean update(Object key, Object value) throws CacheException {
if ( log.isDebugEnabled() ) log.debug("updating: " + key);
cache.update(key, value);
return true;
}
public boolean insert(Object key, Object value) throws CacheException {
if ( log.isDebugEnabled() ) log.debug("inserting: " + key);
cache.update(key, value);
return true;
}
public void evict(Object key) throws CacheException {
cache.remove(key);
}
public void remove(Object key) throws CacheException {
if ( log.isDebugEnabled() ) log.debug("removing: " + key);
cache.remove(key);
}
public void clear() throws CacheException {
log.debug("clearing");
cache.clear();
}
public void destroy() {
try {
cache.destroy();
}
catch (Exception e) {
log.warn("could not destroy cache", e);
}
}
public void setCache(Cache cache) {
this.cache = cache;
}
public Cache getCache() {
return cache;
}
/**
* Do nothing.
*/
public boolean afterInsert(Object key, Object value, Object version)
throws CacheException {
return false;
}
/**
* Do nothing.
*/
public boolean afterUpdate(Object key, Object value, Object version, SoftLock clientLock)
throws CacheException {
return false;
}
public String toString() {
return cache + "(transactional)";
}
}
上一篇:
Transaction.java
下一篇:
“政治先于社会”:认同政治学的政治与社会概念