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

LinkedBlockingQueue.clear介绍

[英]Atomically removes all of the elements from this queue. The queue will be empty after this call returns.
[中]以原子方式从此队列中删除所有元素。此调用返回后，队列将为空。

代码示例

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

/**
  * Clear the list of queued reader events if we are not interested in sending any pending events to any registering record reader.
  */
 public void clearQueuedEvents() {
  queuedEvents.clear();
 }
}

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

public void clear() {
    loggers.clear();
    eventQueue.clear();
  }
}

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

public void clear() {
 queue.clear();
 outputString = null;
}

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

public void clear() {
    loggers.clear();
    eventQueue.clear();
  }
}

代码示例来源：origin: twitter/distributedlog

public void clear() {
  readAheadRecords.clear();
  cacheBytes.set(0L);
}

代码示例来源：origin: alibaba/canal

public void release() {
  running = false;
  this.currentSize = 0;
  binlogList.clear();
  downloadQueue.clear();
  try {
    downloadThread.interrupt();
    downloadThread.join();// 等待其结束
  } catch (InterruptedException e) {
    // ignore
  } finally {
    downloadThread = null;
  }
}

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

public static void emptyCommBufferPool() {
 for (LinkedBlockingQueue<ByteBuffer> q : commBufferMap.values()) {
  q.clear();
 }
}

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

@Override
public void shutdown() {
  finished = true;
  queuedRequests.clear();
  queuedRequests.add(Request.requestOfDeath);
  nextProcessor.shutdown();
}

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

public void shutdown() {
    LOG.info("Shutting down");
    submittedRequests.clear();
    submittedRequests.add(Request.requestOfDeath);
    nextProcessor.shutdown();
  }
}

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

public void shutdown() {
  LOG.info("Shutting down");
  finished = true;
  queuedRequests.clear();
  queuedRequests.add(Request.requestOfDeath);
  nextProcessor.shutdown();
}

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

/**
 * Shutdown the processor.
 */
public void shutdown() {
  LOG.info("Shutting down");
  finished = true;
  queuedRequests.clear();
  queuedRequests.add(Request.requestOfDeath);
  nextProcessor.shutdown();
}

代码示例来源：origin: Red5/red5-server

/** {@inheritDoc} */
@Override
public long getPendingMessages() {
  log.debug("Checking pending queue size. Session id: {} closing: {} state: {}", sessionId, closing, state);
  if (state.getState() == RTMP.STATE_DISCONNECTED) {
    log.debug("Connection is disconnected");
    pendingOutMessages.clear();
  }
  return pendingOutMessages.size();
}

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

private void closeReaderAndResetTrackers() {
  inflight.clear();
  tracker.offsets.clear();
  retryList.clear();
  reader.close();
  reader = null;
  releaseLockAndLog(lock, spoutId);
  lock = null;
}

代码示例来源：origin: org.apache.zookeeper/zookeeper

@Override
public void shutdown() {
  finished = true;
  queuedRequests.clear();
  queuedRequests.add(Request.requestOfDeath);
  nextProcessor.shutdown();
}

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

private void leaveInstance(Vote v) {
  if(LOG.isDebugEnabled()){
    LOG.debug("About to leave FLE instance: leader={}, zxid=0x{}, my id={}, my state={}",
      v.getId(), Long.toHexString(v.getZxid()), self.getId(), self.getPeerState());
  }
  recvqueue.clear();
}

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

private void halt() {
  stoppedMainLoop = true;
  stopped = true;
  wakeupOnEmpty();
  wakeup();
  queuedRequests.clear();
  if (workerPool != null) {
    workerPool.stop();
  }
}

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

@Override
  public void shutdown() {
    LOG.info("shutdown MockProposalRequestProcessor");
    proposals.clear();
    if (commitProcessor != null) {
      commitProcessor.shutdown();
    }
  }
}

代码示例来源：origin: org.apache.zookeeper/zookeeper

private void leaveInstance(Vote v) {
  if(LOG.isDebugEnabled()){
    LOG.debug("About to leave FLE instance: leader="
      + v.getId() + ", zxid=0x" +
      Long.toHexString(v.getZxid()) + ", my id=" + self.getId()
      + ", my state=" + self.getPeerState());
  }
  recvqueue.clear();
}

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

public void verify(List<EventType> expected) throws InterruptedException{
    WatchedEvent event;
    int count = 0;
    while (count < expected.size()
        && (event = events.poll(30, TimeUnit.SECONDS)) != null)
    {
      Assert.assertEquals(expected.get(count), event.getType());
      count++;
    }
    Assert.assertEquals(expected.size(), count);
    events.clear();
  }
}

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

/**
 * clear removes all elements
 */
public void testClear() {
  LinkedBlockingQueue q = populatedQueue(SIZE);
  q.clear();
  assertTrue(q.isEmpty());
  assertEquals(0, q.size());
  assertEquals(SIZE, q.remainingCapacity());
  q.add(one);
  assertFalse(q.isEmpty());
  assertTrue(q.contains(one));
  q.clear();
  assertTrue(q.isEmpty());
}