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

LinkedBlockingQueue.addAll介绍

暂无

代码示例

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

private void addEvents(TezTaskAttemptID taskAttemptID, Collection<TezEvent> events) {
  if (events != null && !events.isEmpty()) {
   eventsToSend.addAll(events);
  }
 }
}

代码示例来源：origin: qunarcorp/qmq

@Override
public void push(List<PulledMessage> messages) {
  for (int i = 0; i < messages.size(); i++) {
    final PulledMessage message = messages.get(i);
    if (!push(message)) {
      messageBuffer.addAll(messages.subList(i, messages.size()));
      break;
    }
  }
}

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

private void collectLedgersFromDL(final URI uri,
                 final com.twitter.distributedlog.DistributedLogManagerFactory factory,
                 final Set<Long> ledgers) throws IOException {
  logger.info("Enumerating {} to collect streams.", uri);
  Collection<String> streams = factory.enumerateAllLogsInNamespace();
  final LinkedBlockingQueue<String> streamQueue = new LinkedBlockingQueue<String>();
  streamQueue.addAll(streams);
  logger.info("Collected {} streams from uri {} : {}",
        new Object[] { streams.size(), uri, streams });
  executeAction(streamQueue, 10, new Action<String>() {
    @Override
    public void execute(String stream) throws IOException {
      collectLedgersFromStream(factory, stream, ledgers);
    }
  });
}

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

private Map<String, Long> calculateStreamSpaceUsage(
    final URI uri, final com.twitter.distributedlog.DistributedLogManagerFactory factory)
  throws IOException {
  Collection<String> streams = factory.enumerateAllLogsInNamespace();
  final LinkedBlockingQueue<String> streamQueue = new LinkedBlockingQueue<String>();
  streamQueue.addAll(streams);
  final Map<String, Long> streamSpaceUsageMap =
      new ConcurrentSkipListMap<String, Long>();
  final AtomicInteger numStreamsCollected = new AtomicInteger(0);
  executeAction(streamQueue, 10, new Action<String>() {
    @Override
    public void execute(String stream) throws IOException {
      streamSpaceUsageMap.put(stream,
          calculateStreamSpaceUsage(factory, stream));
      if (numStreamsCollected.incrementAndGet() % 1000 == 0) {
        logger.info("Calculated {} streams from uri {}.", numStreamsCollected.get(), uri);
      }
    }
  });
  return streamSpaceUsageMap;
}

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

final LinkedBlockingQueue<Long> ledgerQueue =
    new LinkedBlockingQueue<Long>();
ledgerQueue.addAll(ledgers);
for (int i = 0; i < numThreads; i++) {
  final int tid = i;

代码示例来源：origin: apache/incubator-druid

Fetcher(
  CacheManager<T> cacheManager,
  List<T> objects,
  ExecutorService fetchExecutor,
  @Nullable File temporaryDirectory,
  PrefetchConfig prefetchConfig
)
{
 this.cacheManager = cacheManager;
 this.objects = objects;
 this.fetchExecutor = fetchExecutor;
 this.temporaryDirectory = temporaryDirectory;
 this.prefetchConfig = prefetchConfig;
 this.prefetchEnabled = prefetchConfig.getMaxFetchCapacityBytes() > 0;
 this.numRemainingObjects = objects.size();
 // (*) If cache is initialized, put all cached files to the queue.
 this.fetchedFiles.addAll(cacheManager.getFiles());
 this.nextFetchIndex = fetchedFiles.size();
 if (cacheManager.isEnabled() || prefetchEnabled) {
  Preconditions.checkNotNull(temporaryDirectory, "temporaryDirectory");
 }
 if (prefetchEnabled) {
  fetchIfNeeded(0L);
 }
}

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

final LinkedBlockingQueue<String> streamQueue =
    new LinkedBlockingQueue<String>();
streamQueue.addAll(streams);
final Map<String, StreamCandidate> candidateMap =
    new ConcurrentSkipListMap<String, StreamCandidate>();

代码示例来源：origin: qunarcorp/qmq

private void setResult(PullMessageFuture future, List<Message> messages) {
  int expectedSize = future.getExpectedSize();
  if (expectedSize <= 0) {
    localBuffer.addAll(messages);
    future.set(Collections.<Message>emptyList());
    return;
  }
  List<Message> result = new ArrayList<>(expectedSize);
  int bufferSize = localBuffer.size();
  if (bufferSize > 0) {
    localBuffer.drainTo(result, Math.min(expectedSize, bufferSize));
  }
  int need = expectedSize - result.size();
  if (need <= 0) {
    localBuffer.addAll(messages);
    future.set(result);
    return;
  }
  result.addAll(head(messages, need));
  localBuffer.addAll(tail(messages, need));
  future.set(result);
}

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

/**
 * addAll of a collection with any null elements throws NPE after
 * possibly adding some elements
 */
public void testAddAll3() {
  LinkedBlockingQueue q = new LinkedBlockingQueue(SIZE);
  Integer[] ints = new Integer[SIZE];
  for (int i = 0; i < SIZE - 1; ++i)
    ints[i] = new Integer(i);
  Collection<Integer> elements = Arrays.asList(ints);
  try {
    q.addAll(elements);
    shouldThrow();
  } catch (NullPointerException success) {}
}

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

/**
 * addAll throws IllegalStateException if not enough room
 */
public void testAddAll4() {
  LinkedBlockingQueue q = new LinkedBlockingQueue(SIZE - 1);
  Integer[] ints = new Integer[SIZE];
  for (int i = 0; i < SIZE; ++i)
    ints[i] = new Integer(i);
  Collection<Integer> elements = Arrays.asList(ints);
  try {
    q.addAll(elements);
    shouldThrow();
  } catch (IllegalStateException success) {}
}

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

final AtomicInteger numPendings = new AtomicInteger(ledgers.size());
final LinkedBlockingQueue<Long> ledgersQueue = new LinkedBlockingQueue<Long>();
ledgersQueue.addAll(ledgers);

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

/**
 * Queue contains all elements, in traversal order, of successful addAll
 */
public void testAddAll5() {
  Integer[] empty = new Integer[0];
  Integer[] ints = new Integer[SIZE];
  for (int i = 0; i < SIZE; ++i)
    ints[i] = new Integer(i);
  LinkedBlockingQueue q = new LinkedBlockingQueue(SIZE);
  assertFalse(q.addAll(Arrays.asList(empty)));
  assertTrue(q.addAll(Arrays.asList(ints)));
  for (int i = 0; i < SIZE; ++i)
    assertEquals(ints[i], q.poll());
}

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

/**
 * addAll(this) throws IllegalArgumentException
 */
public void testAddAllSelf() {
  LinkedBlockingQueue q = populatedQueue(SIZE);
  try {
    q.addAll(q);
    shouldThrow();
  } catch (IllegalArgumentException success) {}
}

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

eventsToSend.addAll(eventsArg);

代码示例来源：origin: wangdan/AisenWeiBo

mPictures.addAll(pictureList);
offlinePictureSize = mPictures.size();
Logger.d(TAG, "分组%s新增%d张待下载图片", group.getName(), pictureList.size());

代码示例来源：origin: xuxueli/xxl-mq

@Override
public int addMessages(List<XxlMqMessage> messages) {
  newMessageQueue.addAll(messages);
  return messages.size();
}

代码示例来源：origin: org.apache.tez/tez-runtime-internals

private void addEvents(TezTaskAttemptID taskAttemptID, Collection<TezEvent> events) {
  if (events != null && !events.isEmpty()) {
   eventsToSend.addAll(events);
  }
 }
}

代码示例来源：origin: org.opendaylight.yangtools/util

@Override
@SuppressWarnings("checkstyle:parameterName")
public boolean addAll(final Collection<? extends E> c) {
  try {
    return super.addAll(c);
  } finally {
    updateLargestQueueSize();
  }
}

代码示例来源：origin: org.apache.logging.log4j/log4j-flume-ng

@Override
  public Status appendBatch(final List<AvroFlumeEvent> events)
    throws AvroRemoteException {
    Preconditions.checkState(eventQueue.addAll(events));
    return Status.OK;
  }
}

代码示例来源：origin: termux/termux-api

@Override
public void onResults(Bundle results) {
  List<String> recognitions = results.getStringArrayList(SpeechRecognizer.RESULTS_RECOGNITION);
  TermuxApiLogger.error("RecognitionListener#onResults(" + recognitions + ")");
  queueu.addAll(recognitions);
}