java.util.concurrent.LinkedBlockingDeque.offerLast()方法的使用及代码示例

x33g5p2x  于2022-01-23 转载在 其他  
字(4.7k)|赞(0)|评价(0)|浏览(155)

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

LinkedBlockingDeque.offerLast介绍

暂无

代码示例

代码示例来源:origin: robovm/robovm

/**
 * @throws NullPointerException if the specified element is null
 */
public boolean offer(E e) {
  return offerLast(e);
}

代码示例来源:origin: robovm/robovm

/**
 * @throws NullPointerException {@inheritDoc}
 * @throws InterruptedException {@inheritDoc}
 */
public boolean offer(E e, long timeout, TimeUnit unit)
  throws InterruptedException {
  return offerLast(e, timeout, unit);
}

代码示例来源:origin: robovm/robovm

/**
 * @throws IllegalStateException {@inheritDoc}
 * @throws NullPointerException  {@inheritDoc}
 */
public void addLast(E e) {
  if (!offerLast(e))
    throw new IllegalStateException("Deque full");
}

代码示例来源:origin: org.apache.hadoop/hadoop-common

/**
 * Iterates over snapshot to capture all Avg metrics into rolling structure
 * {@link MutableRollingAverages#averages}.
 */
private synchronized void rollOverAvgs() {
 if (currentSnapshot == null) {
  return;
 }
 for (Map.Entry<String, MutableRate> entry : currentSnapshot.entrySet()) {
  final MutableRate rate = entry.getValue();
  final LinkedBlockingDeque<SumAndCount> deque = averages.computeIfAbsent(
    entry.getKey(),
    new Function<String, LinkedBlockingDeque<SumAndCount>>() {
     @Override
     public LinkedBlockingDeque<SumAndCount> apply(String k) {
      return new LinkedBlockingDeque<>(numWindows);
     }
    });
  final SumAndCount sumAndCount = new SumAndCount(
    rate.lastStat().total(),
    rate.lastStat().numSamples());
  /* put newest sum and count to the end */
  if (!deque.offerLast(sumAndCount)) {
   deque.pollFirst();
   deque.offerLast(sumAndCount);
  }
 }
 setChanged();
}

代码示例来源:origin: MobiVM/robovm

/**
 * @throws NullPointerException {@inheritDoc}
 * @throws InterruptedException {@inheritDoc}
 */
public boolean offer(E e, long timeout, TimeUnit unit)
  throws InterruptedException {
  return offerLast(e, timeout, unit);
}

代码示例来源:origin: com.bugvm/bugvm-rt

/**
 * @throws NullPointerException if the specified element is null
 */
public boolean offer(E e) {
  return offerLast(e);
}

代码示例来源:origin: org.apidesign.bck2brwsr/emul

/**
 * @throws NullPointerException if the specified element is null
 */
public boolean offer(E e) {
  return offerLast(e);
}

代码示例来源:origin: ibinti/bugvm

/**
 * @throws NullPointerException if the specified element is null
 */
public boolean offer(E e) {
  return offerLast(e);
}

代码示例来源:origin: ibinti/bugvm

/**
 * @throws NullPointerException {@inheritDoc}
 * @throws InterruptedException {@inheritDoc}
 */
public boolean offer(E e, long timeout, TimeUnit unit)
  throws InterruptedException {
  return offerLast(e, timeout, unit);
}

代码示例来源:origin: FlexoVM/flexovm

/**
 * @throws NullPointerException {@inheritDoc}
 * @throws InterruptedException {@inheritDoc}
 */
public boolean offer(E e, long timeout, TimeUnit unit)
  throws InterruptedException {
  return offerLast(e, timeout, unit);
}

代码示例来源:origin: org.codehaus.jsr166-mirror/jsr166

/**
 * @throws NullPointerException if the specified element is null
 */
public boolean offer(E e) {
  return offerLast(e);
}

代码示例来源:origin: MobiVM/robovm

/**
 * @throws NullPointerException if the specified element is null
 */
public boolean offer(E e) {
  return offerLast(e);
}

代码示例来源:origin: com.gluonhq/robovm-rt

/**
 * @throws NullPointerException if the specified element is null
 */
public boolean offer(E e) {
  return offerLast(e);
}

代码示例来源:origin: ibinti/bugvm

/**
 * @throws IllegalStateException {@inheritDoc}
 * @throws NullPointerException  {@inheritDoc}
 */
public void addLast(E e) {
  if (!offerLast(e))
    throw new IllegalStateException("Deque full");
}

代码示例来源:origin: MobiVM/robovm

/**
 * @throws IllegalStateException {@inheritDoc}
 * @throws NullPointerException  {@inheritDoc}
 */
public void addLast(E e) {
  if (!offerLast(e))
    throw new IllegalStateException("Deque full");
}

代码示例来源:origin: com.mobidevelop.robovm/robovm-rt

/**
 * @throws IllegalStateException {@inheritDoc}
 * @throws NullPointerException  {@inheritDoc}
 */
public void addLast(E e) {
  if (!offerLast(e))
    throw new IllegalStateException("Deque full");
}

代码示例来源:origin: com.bugvm/bugvm-rt

/**
 * @throws IllegalStateException {@inheritDoc}
 * @throws NullPointerException  {@inheritDoc}
 */
public void addLast(E e) {
  if (!offerLast(e))
    throw new IllegalStateException("Deque full");
}

代码示例来源:origin: org.apidesign.bck2brwsr/emul

/**
 * @throws IllegalStateException {@inheritDoc}
 * @throws NullPointerException  {@inheritDoc}
 */
public void addLast(E e) {
  if (!offerLast(e))
    throw new IllegalStateException("Deque full");
}

代码示例来源:origin: com.gluonhq/robovm-rt

/**
 * @throws IllegalStateException {@inheritDoc}
 * @throws NullPointerException  {@inheritDoc}
 */
public void addLast(E e) {
  if (!offerLast(e))
    throw new IllegalStateException("Deque full");
}

代码示例来源:origin: jtulach/bck2brwsr

/**
 * @throws IllegalStateException {@inheritDoc}
 * @throws NullPointerException  {@inheritDoc}
 */
public void addLast(E e) {
  if (!offerLast(e))
    throw new IllegalStateException("Deque full");
}

相关文章

微信公众号

最新文章

更多