本文整理了Java中java.util.concurrent.ConcurrentSkipListMap.isEmpty()
方法的一些代码示例,展示了ConcurrentSkipListMap.isEmpty()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。ConcurrentSkipListMap.isEmpty()
方法的具体详情如下:
包路径:java.util.concurrent.ConcurrentSkipListMap
类名称:ConcurrentSkipListMap
方法名:isEmpty
[英]Returns true if this map contains no key-value mappings.
[中]如果此映射不包含键值映射,则返回true。
代码示例来源:origin: apache/hbase
public boolean hasRegionsInTransition() {
return !regionInTransition.isEmpty();
}
代码示例来源:origin: lealone/Lealone
@Override
public boolean isEmpty() {
return skipListMap.isEmpty();
}
代码示例来源:origin: lealone/Lealone
public boolean needMerge() {
return !buffer.isEmpty();
}
代码示例来源:origin: lealone/Lealone
@Override
public boolean isEmpty() {
return buffer.isEmpty() && map.isEmpty();
}
代码示例来源:origin: apache/hbase
public List<RegionState> getRegionFailedOpen() {
if (regionFailedOpen.isEmpty()) return Collections.emptyList();
ArrayList<RegionState> regions = new ArrayList<RegionState>(regionFailedOpen.size());
for (RegionFailedOpen r: regionFailedOpen.values()) {
regions.add(r.getRegionStateNode().toRegionState());
}
return regions;
}
代码示例来源:origin: Alluxio/alluxio
@Override
public boolean hasChildren(InodeDirectoryView inode) {
Optional<Collection<Long>> cached = mListingCache.getCachedChildIds(inode.getId());
if (cached.isPresent()) {
return !cached.get().isEmpty();
}
return !mEdgeCache.getChildIds(inode.getId()).isEmpty() || mBackingStore.hasChildren(inode);
}
代码示例来源:origin: qunarcorp/qmq
@Override
public boolean clean(Long key) {
if (segments.isEmpty()) return false;
if (segments.lastKey() < key) return false;
DelaySegment segment = segments.remove(key);
if (null == segment) {
LOGGER.error("clean delay segment log failed,segment:{}", logDir, key);
return false;
}
if (!segment.destroy()) {
LOGGER.warn("remove delay segment failed.segment:{}", segment);
return false;
}
LOGGER.info("remove delay segment success.segment:{}", segment);
return true;
}
代码示例来源:origin: apache/ignite
/**
* @return Backup entries.
*/
@Nullable Collection<CacheContinuousQueryEntry> flushOnExchange() {
TreeMap<Long, CacheContinuousQueryEntry> ret = null;
int size = backupQ.sizex();
if (size > 0) {
ret = new TreeMap<>();
for (int i = 0; i < size; i++) {
CacheContinuousQueryEntry e = backupQ.pollFirst();
if (e != null)
ret.put(e.updateCounter(), e);
else
break;
}
}
Batch batch = curBatch.get();
if (batch != null)
ret = batch.flushCurrentEntries(ret);
if (!pending.isEmpty()) {
if (ret == null)
ret = new TreeMap<>();
for (CacheContinuousQueryEntry e : pending.values())
ret.put(e.updateCounter(), e);
}
return ret != null ? ret.values() : null;
}
代码示例来源:origin: apache/hive
try {
int fileLocked = 0, fileUnlocked = 0, fileEvicted = 0, fileMoving = 0;
if (e.getValue().getCache().isEmpty()) continue;
List<LlapDataBuffer> lockedBufs = null;
if (LlapIoImpl.LOCKING_LOGGER.isTraceEnabled()) {
代码示例来源:origin: apache/incubator-druid
@Override
public void stop()
{
synchronized (lock) {
if (currentlyProcessing != null) {
executeCallbacks(currentlyProcessing.getCallbacks());
currentlyProcessing = null;
}
if (!segmentsToDrop.isEmpty()) {
for (SegmentHolder holder : segmentsToDrop.values()) {
executeCallbacks(holder.getCallbacks());
}
}
segmentsToDrop.clear();
if (!segmentsToLoad.isEmpty()) {
for (SegmentHolder holder : segmentsToLoad.values()) {
executeCallbacks(holder.getCallbacks());
}
}
segmentsToLoad.clear();
queuedSize.set(0L);
failedAssignCount.set(0);
stopped = true;
}
}
代码示例来源:origin: apache/incubator-druid
if (!segmentsToDrop.isEmpty()) {
currentlyProcessing = segmentsToDrop.firstEntry().getValue();
log.debug("Server[%s] dropping [%s]", basePath, currentlyProcessing.getSegmentId());
} else if (!segmentsToLoad.isEmpty()) {
currentlyProcessing = segmentsToLoad.firstEntry().getValue();
log.debug("Server[%s] loading [%s]", basePath, currentlyProcessing.getSegmentId());
代码示例来源:origin: apache/ignite
@Override public void onEvent(Event evt) {
int evtType = evt.type();
assert evtType == EVT_NODE_FAILED || evtType == EVT_NODE_LEFT;
if (affMap.isEmpty())
return; // Skip empty affinity map.
final DiscoveryEvent discoEvt = (DiscoveryEvent)evt;
// Clean up affinity functions if such cache no more exists.
final Collection<String> caches = ctx.cache().cacheNames();
final Collection<AffinityAssignmentKey> rmv = new HashSet<>();
for (AffinityAssignmentKey key : affMap.keySet()) {
if (!caches.contains(key.cacheName) || key.topVer.topologyVersion() < discoEvt.topologyVersion() - 10)
rmv.add(key);
}
if (!rmv.isEmpty()) {
ctx.timeout().addTimeoutObject(
new GridTimeoutObjectAdapter(
IgniteUuid.fromUuid(ctx.localNodeId()),
AFFINITY_MAP_CLEAN_UP_DELAY) {
@Override public void onTimeout() {
affMap.keySet().removeAll(rmv);
}
});
}
}
};
代码示例来源:origin: qunarcorp/qmq
private void recover() {
if (segments.isEmpty()) {
return;
代码示例来源:origin: qunarcorp/qmq
public LogSegment allocOrResetSegments(final long expectedOffset) {
final long baseOffset = computeBaseOffset(expectedOffset);
if (segments.isEmpty()) {
return allocSegment(baseOffset);
}
if (nextSegmentBaseOffset() == baseOffset && latestSegment().isFull()) {
return allocSegment(baseOffset);
}
LOG.warn("All segments are too old, need to delete all segment now. Current base offset: {}, expect base offset: {}",
latestSegment().getBaseOffset(), baseOffset);
deleteAllSegments();
return allocSegment(baseOffset);
}
代码示例来源:origin: tjake/Solandra
public ConcurrentNavigableMap<Term, LucandraTermInfo[]> skipTo(Term skip) throws IOException
{
Pair<Term, Term> range = null;
int bufferSize = termList.isEmpty() ? 1 : 3;
// verify we've buffered sufficiently
Map.Entry<Term, Pair<Term, Term>> tailEntry = termQueryBoundries.ceilingEntry(skip);
boolean needsBuffering = true;
if (tailEntry != null)
{
range = tailEntry.getValue();
//skip term must be within a buffered range avoid rebuffering
if (skip.compareTo(range.left) >= 0 && (!range.right.equals(emptyTerm) && skip.compareTo(range.right) < 0))
{
needsBuffering = false;
}
}
ConcurrentNavigableMap<Term, LucandraTermInfo[]> subList = emptyMap;
if (needsBuffering)
{
range = bufferTerms(skip, bufferSize);
}
//logger.info(Thread.currentThread().getName()+" rebuffered "+needsBuffering+" "+range);
if (skip.compareTo(range.left) >= 0 && (!range.right.equals(emptyTerm)) && skip.compareTo(range.right) <= 0)
{
subList = termList.subMap(skip, true, range.right, true);
}
return subList;
}
代码示例来源:origin: palantir/atlasdb
@Override
public long getLatestSequencePreparedOrAccepted() {
if (state.isEmpty()) {
return greatestInLogAtStartup;
} else {
return Math.max(greatestInLogAtStartup, state.lastKey());
}
}
代码示例来源:origin: org.apache.jackrabbit/oak-store-document
/**
* @return <code>true</code> if this branch contains any commits;
* <code>false</code> otherwise.
*/
boolean hasCommits() {
return !commits.isEmpty();
}
代码示例来源:origin: co.cask.hbase/hbase
/**
* @return True if regions in transition.
*/
public boolean isRegionsInTransition() {
synchronized (this.regionsInTransition) {
return !this.regionsInTransition.isEmpty();
}
}
代码示例来源:origin: pravega/pravega
private void releaseIfEmptyInflight() {
synchronized (lock) {
if (inflight.isEmpty()) {
log.trace("Inflight empty for writer {}", writerId);
waitingInflight.release();
}
}
}
代码示例来源:origin: org.jclouds.api/nova
public URI getURI() {
if (orderedSelfReferences.isEmpty())
populateOrderedSelfReferences();
return orderedSelfReferences.firstEntry().getValue();
}
内容来源于网络,如有侵权,请联系作者删除!