本文整理了Java中net.sf.ehcache.Ehcache.isNodeBulkLoadEnabled()
方法的一些代码示例,展示了Ehcache.isNodeBulkLoadEnabled()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Ehcache.isNodeBulkLoadEnabled()
方法的具体详情如下:
包路径:net.sf.ehcache.Ehcache
类名称:Ehcache
方法名:isNodeBulkLoadEnabled
[英]Returns true if the current node is in bulk-load mode. Returns false otherwise.
NOTE: if this method returns true, #isClusterBulkLoadEnabled() method will always return true. Applies to caches clustered with Terracotta only.
[中]如果当前节点处于批量加载模式,则返回true。否则返回false。
注意:如果此方法返回true,#isClusterBulkLoadEnabled()方法将始终返回true。仅适用于使用Terracotta群集的缓存。
代码示例来源:origin: net.sf.ehcache/ehcache
/**
* {@inheritDoc}
*/
public boolean isNodeBulkLoadEnabled() throws UnsupportedOperationException, TerracottaNotRunningException {
return underlyingCache.isNodeBulkLoadEnabled();
}
代码示例来源:origin: net.sf.ehcache/ehcache
/**
* {@inheritDoc}
*/
public boolean isNodeBulkLoadEnabled() throws UnsupportedOperationException, TerracottaNotRunningException {
// THIS IS GENERATED CODE -- DO NOT HAND MODIFY!
Thread t = Thread.currentThread();
ClassLoader prev = t.getContextClassLoader();
t.setContextClassLoader(this.classLoader);
try {
return this.cache.isNodeBulkLoadEnabled();
} finally {
t.setContextClassLoader(prev);
}
}
代码示例来源:origin: net.sf.ehcache/ehcache
/**
* {@inheritDoc}
*/
@Override
public boolean isNodeBulkLoadEnabled() {
return cache.getCacheConfiguration().isTerracottaClustered() && cache.isNodeBulkLoadEnabled();
}
代码示例来源:origin: net.sf.ehcache/ehcache
private static void requestBulkLoadEnabled(Ehcache cache) {
bulkloadLock.lock();
try {
boolean prior = cache.isNodeBulkLoadEnabled();
// yes, this is racy. we can do no better until we have per-thread bulk loading
if (prior) {
String key = cache.getCacheManager().getName() + "/" + cache.getName();
AtomicInteger permits = bulkLoadTrackingMap.get(key);
if (permits == null) {
// first time in. actually switch it
permits = new AtomicInteger(1);
bulkLoadTrackingMap.put(key, permits);
cache.setNodeBulkLoadEnabled(true);
} else {
permits.incrementAndGet();
}
}
} finally {
bulkloadLock.unlock();
}
}
代码示例来源:origin: org.apache.servicemix.bundles/org.apache.servicemix.bundles.ehcache
/**
* {@inheritDoc}
*/
public boolean isNodeBulkLoadEnabled() throws UnsupportedOperationException, TerracottaNotRunningException {
return underlyingCache.isNodeBulkLoadEnabled();
}
代码示例来源:origin: net.sf.ehcache.internal/ehcache-core
/**
* {@inheritDoc}
*/
public boolean isNodeBulkLoadEnabled() throws UnsupportedOperationException, TerracottaNotRunningException {
return underlyingCache.isNodeBulkLoadEnabled();
}
代码示例来源:origin: org.apache.servicemix.bundles/org.apache.servicemix.bundles.ehcache
/**
* {@inheritDoc}
*/
public boolean isNodeBulkLoadEnabled() {
return cache.isNodeBulkLoadEnabled();
}
代码示例来源:origin: org.sonatype.nexus.bundles/org.sonatype.nexus.bundles.ehcache
/**
* {@inheritDoc}
*/
public boolean isNodeBulkLoadEnabled() throws UnsupportedOperationException, TerracottaNotRunningException {
return underlyingCache.isNodeBulkLoadEnabled();
}
代码示例来源:origin: org.apache.servicemix.bundles/org.apache.servicemix.bundles.ehcache
/**
* {@inheritDoc}
*/
public boolean isNodeBulkLoadEnabled() throws UnsupportedOperationException, TerracottaNotRunningException {
// THIS IS GENERATED CODE -- DO NOT HAND MODIFY!
Thread t = Thread.currentThread();
ClassLoader prev = t.getContextClassLoader();
t.setContextClassLoader(this.classLoader);
try {
return this.cache.isNodeBulkLoadEnabled();
} finally {
t.setContextClassLoader(prev);
}
}
代码示例来源:origin: net.sf.ehcache.internal/ehcache-core
/**
* {@inheritDoc}
*/
public boolean isNodeBulkLoadEnabled() throws UnsupportedOperationException, TerracottaNotRunningException {
// THIS IS GENERATED CODE -- DO NOT HAND MODIFY!
Thread t = Thread.currentThread();
ClassLoader prev = t.getContextClassLoader();
t.setContextClassLoader(this.classLoader);
try {
return this.cache.isNodeBulkLoadEnabled();
} finally {
t.setContextClassLoader(prev);
}
}
代码示例来源:origin: org.sonatype.nexus.bundles/org.sonatype.nexus.bundles.ehcache
/**
* {@inheritDoc}
*/
public boolean isNodeBulkLoadEnabled() throws UnsupportedOperationException, TerracottaNotRunningException {
// THIS IS GENERATED CODE -- DO NOT HAND MODIFY!
Thread t = Thread.currentThread();
ClassLoader prev = t.getContextClassLoader();
t.setContextClassLoader(this.classLoader);
try {
return this.cache.isNodeBulkLoadEnabled();
} finally {
t.setContextClassLoader(prev);
}
}
代码示例来源:origin: net.sf.ehcache.internal/ehcache-core
/**
* {@inheritDoc}
*/
@Override
public boolean isNodeBulkLoadEnabled() {
return cache.getCacheConfiguration().isTerracottaClustered() && cache.isNodeBulkLoadEnabled();
}
代码示例来源:origin: org.sonatype.nexus.bundles/org.sonatype.nexus.bundles.ehcache
/**
* {@inheritDoc}
*/
@Override
public boolean isNodeBulkLoadEnabled() {
return cache.getCacheConfiguration().isTerracottaClustered() && cache.isNodeBulkLoadEnabled();
}
代码示例来源:origin: org.sonatype.nexus.bundles/org.sonatype.nexus.bundles.ehcache
private static void requestBulkLoadEnabled(Ehcache cache) {
bulkloadLock.lock();
try {
boolean prior = cache.isNodeBulkLoadEnabled();
// yes, this is racy. we can do no better until we have per-thread bulk loading
if (prior) {
String key = cache.getCacheManager().getName() + "/" + cache.getName();
AtomicInteger permits = bulkLoadTrackingMap.get(key);
if (permits == null) {
// first time in. actually switch it
permits = new AtomicInteger(1);
bulkLoadTrackingMap.put(key, permits);
cache.setNodeBulkLoadEnabled(true);
} else {
permits.incrementAndGet();
}
}
} finally {
bulkloadLock.unlock();
}
}
代码示例来源:origin: net.sf.ehcache.internal/ehcache-scheduled-refresh
private static void requestBulkLoadEnabled(Ehcache cache) {
bulkloadLock.lock();
try {
boolean prior = cache.isNodeBulkLoadEnabled();
// yes, this is racy. we can do no better until we have per-thread bulk loading
if (prior) {
String key = cache.getCacheManager().getName() + "/" + cache.getName();
AtomicInteger permits = bulkLoadTrackingMap.get(key);
if (permits == null) {
// first time in. actually switch it
permits = new AtomicInteger(1);
bulkLoadTrackingMap.put(key, permits);
cache.setNodeBulkLoadEnabled(true);
} else {
permits.incrementAndGet();
}
}
} finally {
bulkloadLock.unlock();
}
}
内容来源于网络,如有侵权,请联系作者删除!