本文整理了Java中java.util.concurrent.ConcurrentSkipListSet.iterator()方法的一些代码示例，展示了ConcurrentSkipListSet.iterator()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。ConcurrentSkipListSet.iterator()方法的具体详情如下：
包路径：java.util.concurrent.ConcurrentSkipListSet
类名称：ConcurrentSkipListSet
方法名：iterator

ConcurrentSkipListSet.iterator介绍

[英]Returns an iterator over the elements in this set in ascending order.
[中]按升序返回此集合中元素的迭代器。

代码示例

代码示例来源：origin: de.dentrassi.eclipse.neoscada.utils/org.eclipse.scada.utils

@Override
public Iterator<E> iterator ()
{
  return this.internalSet.iterator ();
}

代码示例来源：origin: com.github.tomakehurst/wiremock-jre8

@Override
public Iterator<StubMapping> iterator() {
  return mappingSet.iterator();
}

代码示例来源：origin: com.vmware.dcp/dcp-common

private void performNodeSelectorChangeMaintenance() {
  Iterator<String> it = this.pendingNodeSelectorsForFactorySynch.iterator();
  while (it.hasNext()) {
    String selectorPath = it.next();
    it.remove();
    performNodeSelectorChangeMaintenance(selectorPath);
  }
}

代码示例来源：origin: org.apache.hadoop/hadoop-yarn-server-resourcemanager

@Override
public Iterator<S> getAssignmentIterator() {
 reorderScheduleEntities();
 return schedulableEntities.iterator();
}

代码示例来源：origin: deegree/deegree3

/**
 * Writes all current caches to their cache files, but leaves the in memory cached rasters alone.
 */
public static void flush() {
  synchronized ( MEM_LOCK ) {
    Iterator<CacheRasterReader> it = cache.iterator();
    while ( it != null && it.hasNext() ) {
      CacheRasterReader next = it.next();
      if ( next != null ) {
        next.flush();
      }
    }
  }
}

代码示例来源：origin: cojen/Tupl

@Override
public void compact(long index) throws IOException {
  Iterator<LKey<TermLog>> it = mTermLogs.iterator();
  while (it.hasNext()) {
    TermLog termLog = (TermLog) it.next();
    if (termLog.compact(index)) {
      it.remove();
    } else {
      break;
    }
  }
}

代码示例来源：origin: net.sf.extcos/extcos

private void blacklistOnSets(final Resource resource) {
  Iterator<SoftReference<BlacklistAwareSet<Resource>>> setIterator =
      managedSets.iterator();
  while (setIterator.hasNext()) {
    SoftReference<BlacklistAwareSet<Resource>> reference =
        setIterator.next();
    BlacklistAwareSet<Resource> iterator = reference.get();
    if (iterator == null || reference.isEnqueued()) {
      setIterator.remove();
    } else {
      iterator.addToBlacklist(resource);
    }
  }
}

代码示例来源：origin: net.sf.extcos/extcos

private void blacklistOnIterators(final Resource resource) {
  Iterator<SoftReference<BlacklistAwareIterator<Resource>>> iteratorIterator =
      managedIterators.iterator();
  while (iteratorIterator.hasNext()) {
    SoftReference<BlacklistAwareIterator<Resource>> reference =
        iteratorIterator.next();
    BlacklistAwareIterator<Resource> iterator = reference.get();
    if (iterator == null || reference.isEnqueued()) {
      iteratorIterator.remove();
    } else {
      iterator.addToBlacklist(resource);
    }
  }
}

代码示例来源：origin: deegree/deegree3

/**
 * Iterates over all current cache directories and calls dispose on their cache files.
 */
public static void dispose() {
  synchronized ( MEM_LOCK ) {
    Iterator<CacheRasterReader> it = cache.iterator();
    long allocatedMem = 0;
    int i = 1;
    while ( it != null && it.hasNext() ) {
      CacheRasterReader next = it.next();
      if ( next != null ) {
        LOG.debug( "{}: Disposing for file: {}", i++, next.file() );
        // currentlyUsedMemory -= next.dispose( false );
        allocatedMem += next.dispose( false );
      }
    }
    LOG.debug( "Disposing allocated {} MB on the heap.",
          ( Math.round( ( allocatedMem / ( 1024 * 1024d ) ) * 100d ) / 100d ) );
  }
}

代码示例来源：origin: deegree/deegree3

/**
 * Iterates over all known readers and (re) calculates their in memory data.
 */
private static void updateCurrentlyUsedSpace() {
  synchronized ( MEM_LOCK ) {
    LOG.debug( "Updating estimation of in-memory cache." );
    long cum = 0;
    long onDisk = 0;
    Iterator<CacheRasterReader> it = cache.iterator();
    while ( it != null && it.hasNext() ) {
      CacheRasterReader next = it.next();
      if ( next != null ) {
        cum += next.currentApproxMemory();
        onDisk += next.cacheFileSize();
      }
    }
    LOG.debug( "Resetting currently used memory from: {} to: {}", ( currentlyUsedMemory / ( 1024 * 1024d ) ),
          ( cum / ( 1024 * 1024d ) ) );
    LOG.debug( "Resetting currently used space on disk from: {} to: {}",
          ( currentlyUsedDisk / ( 1024 * 1024d ) ), ( onDisk / ( 1024 * 1024d ) ) );
    currentlyUsedMemory = cum;
    currentlyUsedDisk = onDisk;
  }
}

代码示例来源：origin: org.everit.cluster/org.everit.cluster.invalidationmap.support

numberIt = gotMessageNumbers.iterator();
long endingNumber = numberIt.next().longValue();
do {
numberIt = gotMessageNumbers.iterator();
while (numberIt.hasNext()) {
 long current = numberIt.next().longValue();

代码示例来源：origin: deegree/deegree3

Iterator<CacheRasterReader> it = cache.iterator();
while ( it != null && it.hasNext() ) {
  CacheRasterReader next = it.next();

代码示例来源：origin: undera/jmeter-plugins

Iterator<Long> itXValues = xValues.iterator();
while (itXValues.hasNext()) {
  long xValue = itXValues.next();

代码示例来源：origin: Audiveris/audiveris

/**
 * Go through all registered to-be-initialized sets, and initialize
 * them, then clear the set of such dirty sets.
 */
public void checkDirtySets ()
{
  int rookies = 0;
  // We use (and clear) the collection of rookies
  for (Iterator<String> it = dirtySets.iterator(); it.hasNext();) {
    String name = it.next();
    rookies++;
    //            System.out.println(
    //                Thread.currentThread().getName() + ": checkDirtySets. name=" +
    //                name);
    UnitNode unit = (UnitNode) getNode(name);
    if (unit.getConstantSet().initialize()) {
      it.remove();
    }
  }
  //        System.out.println(
  //            Thread.currentThread().getName() + ": checkDirtySets. rookies:" +
  //            rookies);
}

代码示例来源：origin: kg.apc/jmeter-plugins-cmn-jmeter

Iterator<Long> itXValues = xValues.iterator();
while (itXValues.hasNext()) {
  long xValue = itXValues.next();

代码示例来源：origin: com.sequoiadb/sequoiadb-driver

return;
Iterator<String> abnormalAddrSetItr = _abnormalAddrs.iterator();
ConfigOptions nwOpt = new ConfigOptions();
String addr = "";

代码示例来源：origin: com.sequoiadb/sequoiadb-driver

int retry = 3;
while (retry-- > 0) {
  Iterator<String> itr = _abnormalAddrs.iterator();
  while (itr.hasNext()) {
    String addr = itr.next();

代码示例来源：origin: jsevellec/cassandra-unit

public KeyRangeIterator(ConcurrentSkipListSet<DecoratedKey> keys)
{
  super((Long) keys.first().getToken().getTokenValue(), (Long) keys.last().getToken().getTokenValue(), keys.size());
  this.iterator = new DKIterator(keys.iterator());
}

代码示例来源：origin: com.strapdata.cassandra/cassandra-all

public KeyRangeIterator(ConcurrentSkipListSet<DecoratedKey> keys)
{
  super((Long) keys.first().getToken().getTokenValue(), (Long) keys.last().getToken().getTokenValue(), keys.size());
  this.iterator = new DKIterator(keys.iterator());
}

代码示例来源：origin: org.apache.cassandra/cassandra-all

public KeyRangeIterator(ConcurrentSkipListSet<DecoratedKey> keys)
{
  super((Long) keys.first().getToken().getTokenValue(), (Long) keys.last().getToken().getTokenValue(), keys.size());
  this.iterator = new DKIterator(keys.iterator());
}