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

LinkedBlockingQueue.toArray介绍

[英]Returns an array containing all of the elements in this queue, in proper sequence.

The returned array will be "safe" in that no references to it are maintained by this queue. (In other words, this method must allocate a new array). The caller is thus free to modify the returned array.

This method acts as bridge between array-based and collection-based APIs.
[中]按正确的顺序返回包含此队列中所有元素的数组。
返回的数组将是“安全的”，因为此队列不维护对它的引用。（换句话说，此方法必须分配一个新数组）。因此，调用者可以自由修改返回的数组。
此方法充当基于阵列和基于集合的API之间的桥梁。

代码示例

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

/**
 * toArray contains all elements in FIFO order
 */
public void testToArray() {
  LinkedBlockingQueue q = populatedQueue(SIZE);
  Object[] o = q.toArray();
  for (int i = 0; i < o.length; i++)
    assertSame(o[i], q.poll());
}

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

/**
 * toArray(incompatible array type) throws ArrayStoreException
 */
public void testToArray1_BadArg() {
  LinkedBlockingQueue q = populatedQueue(SIZE);
  try {
    q.toArray(new String[10]);
    shouldThrow();
  } catch (ArrayStoreException success) {}
}

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

/**
 * toArray(a) contains all elements in FIFO order
 */
public void testToArray2() throws InterruptedException {
  LinkedBlockingQueue<Integer> q = populatedQueue(SIZE);
  Integer[] ints = new Integer[SIZE];
  Integer[] array = q.toArray(ints);
  assertSame(ints, array);
  for (int i = 0; i < ints.length; i++)
    assertSame(ints[i], q.poll());
}

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

if(notificationQueue !=null){
  LinkedBlockingQueue<SimpleApnsPushNotification>  queue =  ( LinkedBlockingQueue<SimpleApnsPushNotification> )notificationQueue;
  Object[] objectMess = queue.toArray(); //get messages still in queue
  for(Object o : objectMess){
    if(o instanceof SimpleApnsPushNotification) {

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

public <E> E[] toArray(E[] a) {
  return delegate.toArray(a);
}

代码示例来源：origin: stackoverflow.com

java.util.concurrent.LinkedBlockingQueue.toArray()

代码示例来源：origin: rhq-project/rhq

public <T> T[] toArray(T[] a) {
  return m_queue.toArray(a);
}

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

public <T> T[] toArray(final T[] a) {
 return blockingQueue.toArray(a);
}

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

public Object[] toArray() {
  return delegate.toArray();
}

代码示例来源：origin: org.rhq/rhq-enterprise-comm

public Object[] toArray() {
  return m_queue.toArray();
}

代码示例来源：origin: org.rhq/rhq-enterprise-comm

public <T> T[] toArray(T[] a) {
  return m_queue.toArray(a);
}

代码示例来源：origin: rhq-project/rhq

public Object[] toArray() {
  return m_queue.toArray();
}

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

public Object[] toArray() {
 return blockingQueue.toArray();
}

代码示例来源：origin: zhongchengxcr/canal-elasticsearch

public void close() {
  Object[] tuple2Arr = transFormFuture.toArray();
  for (Object obj : tuple2Arr) {
    Future<ElasticsearchMetadata> future = (Future<ElasticsearchMetadata>) obj;
    future.cancel(true);
  }
}

代码示例来源：origin: eventuate-tram/eventuate-tram-core

private List<Message> getMessages() {
 return Arrays.asList(this.messages.toArray(new Message[this.messages.size()]));
}

代码示例来源：origin: com.google/bitcoinj

@Override
  public void execute(Runnable command) {
    if (tasks.size() > 100) {
      log.warn("User thread saturated, memory exhaustion may occur.");
      log.warn("Check for deadlocked or slow event handlers. Sample tasks:");
      for (Object task : tasks.toArray()) log.warn(task.toString());
    }
    Uninterruptibles.putUninterruptibly(tasks, command);
  }
}

代码示例来源：origin: org.refcodes/refcodes-io

/**
 * {@inheritDoc}
 */
@Override
public byte[] getBytes() {
  return toPrimitiveType( _datagramQueue.toArray( new Byte[_datagramQueue.size()] ) );
}

代码示例来源：origin: org.refcodes/refcodes-io

/**
 * {@inheritDoc}
 */
@Override
public byte[] getBytes() {
  return toPrimitiveType( _datagramQueue.toArray( new Byte[_datagramQueue.size()] ) );
}

代码示例来源：origin: org.mobicents.diameter/jdiameter-impl

protected boolean processBufferedMessages(Event event) throws AvpDataException {
 if (listeners.size() == 0) {
  try {
   buffer.add(event);
  }
  catch (IllegalStateException e) {
   // FIXME : requires JDK6 : buffer.removeLast();
   Event[] tempBuffer = buffer.toArray(new Event[buffer.size()]);
   buffer.remove(tempBuffer[tempBuffer.length - 1]);
   buffer.add(event);
  }
  return false;
 }
 else {
  return true;
 }
}

代码示例来源：origin: com.github.kaitoy.sneo/sneo-core

public <T> T[] toArray(T[] a) {
 if (isRunning()) {
  return q.toArray(a);
 }
 else {
  return new LinkedBlockingQueue<T>(0).toArray(a);
 }
}