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

LinkedBlockingQueue.iterator介绍

[英]Returns an iterator over the elements in this queue in proper sequence. The elements will be returned in order from first (head) to last (tail).

The returned iterator is a "weakly consistent" iterator that will never throw java.util.ConcurrentModificationException, and guarantees to traverse elements as they existed upon construction of the iterator, and may (but is not guaranteed to) reflect any modifications subsequent to construction.
[中]按正确的顺序返回此队列中元素的迭代器。元素将按从第一个（头部）到最后一个（尾部）的顺序返回。
返回的迭代器是一个“弱一致性”迭代器，它永远不会抛出java。util。ConcurrentModificationException，并保证遍历迭代器构造时存在的元素，并且可能（但不保证）反映构造之后的任何修改。

代码示例

代码示例来源：origin: opentripplanner/OpenTripPlanner

private void colorOverlappingBranches(LinkedBlockingQueue<SPTNode> queue) {
  HashMap<Vertex,Integer> stateHeight = new HashMap<Vertex,Integer>();
  
  Iterator<SPTNode> nodes = queue.iterator();
  while(nodes.hasNext()){
    SPTNode node = nodes.next();
    
    Integer height = stateHeight.get(node.state.getVertex());
    if(height==null){
      height = 0;
    } else{
      height += 1;
    }
    stateHeight.put(node.state.getVertex(),height);
    
    node.setHeight(height);
  }
}

代码示例来源：origin: jankotek/mapdb

/**
 * iterator of empty collection has no elements
 */
public void testEmptyIterator() {
  assertIteratorExhausted(new LinkedBlockingQueue().iterator());
}

代码示例来源：origin: jankotek/mapdb

/**
 * Modifications do not cause iterators to fail
 */
public void testWeaklyConsistentIteration() {
  final LinkedBlockingQueue q = new LinkedBlockingQueue(3);
  q.add(one);
  q.add(two);
  q.add(three);
  for (Iterator it = q.iterator(); it.hasNext();) {
    q.remove();
    it.next();
  }
  assertEquals(0, q.size());
}

代码示例来源：origin: jankotek/mapdb

/**
 * iterator.remove removes current element
 */
public void testIteratorRemove() {
  final LinkedBlockingQueue q = new LinkedBlockingQueue(3);
  q.add(two);
  q.add(one);
  q.add(three);
  Iterator it = q.iterator();
  it.next();
  it.remove();
  it = q.iterator();
  assertSame(it.next(), one);
  assertSame(it.next(), three);
  assertFalse(it.hasNext());
}

代码示例来源：origin: jankotek/mapdb

/**
 * iterator ordering is FIFO
 */
public void testIteratorOrdering() {
  final LinkedBlockingQueue q = new LinkedBlockingQueue(3);
  q.add(one);
  q.add(two);
  q.add(three);
  assertEquals(0, q.remainingCapacity());
  int k = 0;
  for (Iterator it = q.iterator(); it.hasNext();) {
    assertEquals(++k, it.next());
  }
  assertEquals(3, k);
}

代码示例来源：origin: jankotek/mapdb

/**
 * iterator iterates through all elements
 */
public void testIterator() throws InterruptedException {
  LinkedBlockingQueue q = populatedQueue(SIZE);
  Iterator it = q.iterator();
  int i;
  for (i = 0; it.hasNext(); i++)
    assertTrue(q.contains(it.next()));
  assertEquals(i, SIZE);
  assertIteratorExhausted(it);
  it = q.iterator();
  for (i = 0; it.hasNext(); i++)
    assertEquals(it.next(), q.take());
  assertEquals(i, SIZE);
  assertIteratorExhausted(it);
}

代码示例来源：origin: Impetus/Kundera

private void retryDownedHosts()
  {
    Iterator<CassandraHost> iter = downedHostQueue.iterator();
    while (iter.hasNext())
    {
      CassandraHost host = iter.next();
      if (host == null)
      {
        continue;
      }
      boolean reconnected = verifyConnection(host);
      if (reconnected)
      {
        ((CassandraClientFactory) clientFactory).addCassandraHost(host);
        iter.remove();
      }
    }
  }
}

代码示例来源：origin: apache/flink

Iterator<Object> iterator = restoredTaskHarness.getOutput().iterator();
while (iterator.hasNext()) {
  if (iterator.next() instanceof CheckpointBarrier) {

代码示例来源：origin: hector-client/hector

Iterator<CassandraHost> iter = downedHostQueue.iterator();
while( iter.hasNext() ) {
 CassandraHost cassandraHost = iter.next();

代码示例来源：origin: io.snappydata/snappydata-store-core

/**
 * This iterator actually allows creating multiple iterators unlike the
 * default {@link #iterator()} of this class.
 */
public Iterator<Object> reusableIterator() {
 return super.iterator();
}

代码示例来源：origin: io.snappydata/gemfirexd

/**
 * This iterator actually allows creating multiple iterators unlike the
 * default {@link #iterator()} of this class.
 */
public Iterator<Object> reusableIterator() {
 return super.iterator();
}

代码示例来源：origin: davidB/metrics-influxdb

public Iterator<T> iterator() {
    return delegate.iterator();
  }
}

代码示例来源：origin: io.snappydata/gemfirexd-core

/**
 * This iterator actually allows creating multiple iterators unlike the
 * default {@link #iterator()} of this class.
 */
public Iterator<Object> reusableIterator() {
 return super.iterator();
}

代码示例来源：origin: com.nitorcreations/nflow-engine

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

代码示例来源：origin: io.nflow/nflow-engine

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

代码示例来源：origin: xap/xap

private void harvestObsolete() {
  Iterator<Observable> iterator = queue.iterator();
  while (iterator.hasNext()) {
    Observable observable = iterator.next();
    if (observable.isObsolete()) {
      iterator.remove();
    }
  }
}

代码示例来源：origin: kingston-csj/im

@Override
public Iterator<E> iterator() {
  return new Itr(super.iterator());
}

代码示例来源：origin: killme2008/gecko

public void cancelReconnectGroup(final String group) {
  this.canceledGroupSet.add(group);
  final Iterator<ReconnectTask> it = this.tasks.iterator();
  while (it.hasNext()) {
    final ReconnectTask task = it.next();
    if (task.getGroupSet().contains(group)) {
      log.warn("Invalid reconnect request,it is removed,the group set is:" + task.getGroupSet());
      it.remove();
    }
  }
}

代码示例来源：origin: com.taobao.gecko/gecko

public void cancelReconnectGroup(final String group) {
  this.canceledGroupSet.add(group);
  final Iterator<ReconnectTask> it = this.tasks.iterator();
  while (it.hasNext()) {
    final ReconnectTask task = it.next();
    if (task.getGroupSet().contains(group)) {
      log.warn("Invalid reconnect request,it is removed,the group set is:" + task.getGroupSet());
      it.remove();
    }
  }
}

代码示例来源：origin: apptentive/apptentive-android

public void notifyInteractionUpdated(boolean successful) {
  checkConversationQueue();
  ApptentiveNotificationCenter.defaultCenter()
    .postNotification(NOTIFICATION_INTERACTIONS_DID_FETCH,
      NOTIFICATION_KEY_SUCCESSFUL, successful);
  Iterator it = interactionUpdateListeners.iterator();
  while (it.hasNext()) {
    InteractionManager.InteractionUpdateListener listener = (InteractionManager.InteractionUpdateListener) it.next();
    if (listener != null) {
      listener.onInteractionUpdated(successful);
    }
  }
}