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

LinkedBlockingDeque.remove介绍

[英]Retrieves and removes the head of the queue represented by this deque. This method differs from #poll only in that it throws an exception if this deque is empty.

This method is equivalent to #removeFirst().
[中]检索并删除此数据块表示的队列头。此方法与#poll的不同之处在于，如果此deque为空，则会引发异常。
此方法相当于#removeFirst（）。

代码示例

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

public void remove(K entry) {
  synchronized (_lock) {
    for (LinkedBlockingDeque<K> bucket : _buckets) {
      if (bucket.contains(entry)) {
        bucket.remove(entry);
        return;
      }
    }
  }
}

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

private void sendPrimePacket() {
  // assuming the first packet is the priming packet.
  sendPktAndFlush(outgoingQueue.remove());
}

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

/**
 * Clean up shutdown hooks that have been garbage collected.
 */
private void cleanUpShutdownHooks() {
  Reference<? extends ShutdownHook> reference;
  while ((reference = shReferenceQueue.poll()) != null) {
    shutdownHooks.remove(reference);
    final ShutdownHook shutdownHook = reference.get();
    if (shutdownHook != null) { // close this one off if still accessible
      shutdownHook.onShutdown();
    }
  }
}

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

/**
 * Clean up shutdown hooks that have been garbage collected.
 */
private void cleanUpShutdownHooks() {
  Reference<? extends ShutdownHook> reference;
  while ((reference = shReferenceQueue.poll()) != null) {
    shutdownHooks.remove(reference);
    final ShutdownHook shutdownHook = reference.get();
    if (shutdownHook != null) { // close this one off if still accessible
      shutdownHook.onShutdown();
    }
  }
}

代码示例来源：origin: org.glassfish.jersey.core/jersey-client

/**
 * Clean up shutdown hooks that have been garbage collected.
 */
private void cleanUpShutdownHooks() {
  Reference<? extends ShutdownHook> reference;
  while ((reference = shReferenceQueue.poll()) != null) {
    shutdownHooks.remove(reference);
    final ShutdownHook shutdownHook = reference.get();
    if (shutdownHook != null) { // close this one off if still accessible
      shutdownHook.onShutdown();
    }
  }
}

代码示例来源：origin: lealone/Lealone

public void add(long i) {
  if (!deque.offer(i)) {
    Long removed = deque.remove();
    sum.addAndGet(-removed);
    deque.offer(i);
  }
  sum.addAndGet(i);
}

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

@Override
public boolean isEndOfInput() throws Exception {
  if (!open) {
    return true;
  }
  ByteBuffer peek = queue.peek();
  if ((peek != null && peek == VOID)) {
    queue.remove(); // VOID from the top.
    open = false;
    removeCloseListener();
    return true;
  }
  return false;
}

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

/**
 * doWrite handles writing the packets from outgoingQueue via network to server.
 */
private void doWrite(List<Packet> pendingQueue, Packet p, ClientCnxn cnxn) {
  updateNow();
  while (true) {
    if (p != WakeupPacket.getInstance()) {
      if ((p.requestHeader != null) &&
          (p.requestHeader.getType() != ZooDefs.OpCode.ping) &&
          (p.requestHeader.getType() != ZooDefs.OpCode.auth)) {
        p.requestHeader.setXid(cnxn.getXid());
        synchronized (pendingQueue) {
          pendingQueue.add(p);
        }
      }
      sendPktOnly(p);
    }
    if (outgoingQueue.isEmpty()) {
      break;
    }
    p = outgoingQueue.remove();
  }
  // TODO: maybe we should flush in the loop above every N packets/bytes?
  // But, how do we determine the right value for N ...
  channel.flush();
}

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

/**
 * toArray(a) contains all elements in FIFO order
 */
public void testToArray2() {
  LinkedBlockingDeque<Integer> q = populatedDeque(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.remove());
}

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

LOG.warn("Corrupt record replaced by File Channel Integrity " +
   "tool found. Will retrieve next event", e);
 takeList.remove(ptr);
} catch (CorruptEventException ex) {
 channelCounter.incrementEventTakeErrorCount();
 takeList.remove(ptr);

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

/**
 * removeAll(c) removes only those elements of c and reports true if changed
 */
public void testRemoveAll() {
  for (int i = 1; i < SIZE; ++i) {
    BlockingDeque q = populatedDeque(SIZE);
    LinkedBlockingDeque p = populatedDeque(i);
    assertTrue(q.removeAll(p));
    assertEquals(SIZE - i, q.size());
    for (int j = 0; j < i; ++j) {
      Integer x = (Integer)(p.remove());
      assertFalse(q.contains(x));
    }
  }
}

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

/**
 * retainAll(c) retains only those elements of c and reports true if changed
 */
public void testRetainAll() {
  BlockingDeque q = populatedDeque(SIZE);
  LinkedBlockingDeque p = populatedDeque(SIZE);
  for (int i = 0; i < SIZE; ++i) {
    boolean changed = q.retainAll(p);
    if (i == 0)
      assertFalse(changed);
    else
      assertTrue(changed);
    assertTrue(q.containsAll(p));
    assertEquals(SIZE - i, q.size());
    p.remove();
  }
}

代码示例来源：origin: org.apache.commons/commons-jcs-core

/**
 * @param observer
 */
@Override
public void deregisterShutdownObserver( IShutdownObserver observer )
{
  shutdownObservers.remove( observer );
}

代码示例来源：origin: saki4510t/libcommon

public void removeRequest(final int request) {
  for (final Request req: mRequestQueue) {
    if (!mIsRunning || mFinished) break;
    if (req.request == request) {
      mRequestQueue.remove(req);
      mRequestPool.offer(req);
    }
  }
}

代码示例来源：origin: nuls-io/nuls

public void remove(K k) {
  map.remove(k);
  queue.remove(k);
}

代码示例来源：origin: apache/uima-uimaj

private void remove(LinkedBlockingDeque<MultiThreadInfo> pool) {
 boolean wasRemoved = pool.remove(this);
 if (! wasRemoved) {      
  throw new RuntimeException(sb.toString() + "\nnever happen: removing from pool, but wasn't there");
 }
}

代码示例来源：origin: com.alibaba.jstorm/jstorm-core

public void remove(K entry) {
  synchronized (_lock) {
    for (LinkedBlockingDeque<K> bucket : _buckets) {
      if (bucket.contains(entry)) {
        bucket.remove(entry);
        return;
      }
    }
    return;
  }
}

代码示例来源：origin: org.glassfish.jersey.bundles/jaxrs-ri

/**
 * Clean up shutdown hooks that have been garbage collected.
 */
private void cleanUpShutdownHooks() {
  Reference<? extends ShutdownHook> reference;
  while ((reference = shReferenceQueue.poll()) != null) {
    shutdownHooks.remove(reference);
    final ShutdownHook shutdownHook = reference.get();
    if (shutdownHook != null) { // close this one off if still accessible
      shutdownHook.onShutdown();
    }
  }
}

代码示例来源：origin: apache/uima-uimaj

@Override
 public boolean remove(Object o) {
  System.out.println(x((MultiThreadInfo)o, "removing"));
  return super.remove(o);
 }
}

代码示例来源：origin: me.prettyprint/hector-core

void add(double i) {
 if (intervalupdates.intValue() >= UPDATES_PER_INTERVAL)
  return;
 if (!latencies.offer(i)) {
  latencies.remove();
  latencies.offer(i);
 }
 intervalupdates.getAndIncrement();
}