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

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

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

LinkedBlockingDeque.getLast介绍

暂无

代码示例

代码示例来源:origin: com.bazaarvoice.astyanax/astyanax-core

@Override
public boolean check(long currentTimeMillis) {
  int maxCount = config.getConnectionLimiterMaxPendingCount();
  if (maxCount == 0)
    return true;
  // Haven't reached the count limit yet
  if (queue.size() < maxCount) {
    queue.addFirst(currentTimeMillis);
    return true;
  }
  else {
    long last = queue.getLast();
    if (currentTimeMillis - last < config.getConnectionLimiterWindowSize()) {
      return false;
    }
    queue.addFirst(currentTimeMillis);
    queue.removeLast();
    return true;
  }
}

代码示例来源:origin: com.netflix.astyanax/astyanax-core

@Override
public boolean check(long currentTimeMillis) {
  int maxCount = config.getConnectionLimiterMaxPendingCount();
  if (maxCount == 0)
    return true;
  // Haven't reached the count limit yet
  if (queue.size() < maxCount) {
    queue.addFirst(currentTimeMillis);
    return true;
  }
  else {
    long last = queue.getLast();
    if (currentTimeMillis - last < config.getConnectionLimiterWindowSize()) {
      return false;
    }
    queue.addFirst(currentTimeMillis);
    queue.removeLast();
    return true;
  }
}

相关文章

微信公众号

最新文章

更多