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

x33g5p2x  于2022-01-16 转载在 其他  
字(3.1k)|赞(0)|评价(0)|浏览(197)

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

BlockingQueue.removeAll介绍

暂无

代码示例

代码示例来源:origin: apache/hbase

@Override
public boolean removeAll(Collection<?> elements) {
 return underlyingQueue.removeAll(elements);
}

代码示例来源:origin: apache/nifi

processing.removeAll(files);
} finally {
  queueLock.unlock();

代码示例来源:origin: apache/nifi

processing.removeAll(files);
} finally {
  queueLock.unlock();

代码示例来源:origin: org.codehaus.redback.components/spring-taskqueue

public boolean removeAll( List tasks )
  throws ClassCastException, NullPointerException
{
  return queue.removeAll( tasks );
}

代码示例来源:origin: org.apache.archiva.redback.components/spring-taskqueue

public boolean removeAll( List tasks )
  throws ClassCastException, NullPointerException
{
  return queue.removeAll( tasks );
}

代码示例来源:origin: org.jboss.errai.io.netty/netty-transport-sctp

@Override
public boolean removeAll(Collection<?> c) {
  return queue.removeAll(c);
}

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

@Override
public boolean removeAll(
    @SuppressWarnings("PMD.ShortVariable") final Collection<?> c) {
  synchronized (this) {
    return this.queue.removeAll(c);
  }
}

代码示例来源:origin: smallnest/ZKRecipesByExample

@Override
public boolean removeAll(Collection<?> c) {
  return localInternalQueue.removeAll(c);
}

代码示例来源:origin: mycila/pubsub

@Override
public boolean removeAll(Collection<?> c) {
  return delegate.removeAll(c);
}

代码示例来源:origin: com.mycila/mycila-pubsub

@Override
public boolean removeAll(Collection<?> c) {
  return delegate.removeAll(c);
}

代码示例来源:origin: org.deeplearning4j/deeplearning4j-nn

@Override
public boolean removeAll(Collection<?> c) {
  return backingQueue.removeAll(c);
}

代码示例来源:origin: com.aliyun.hbase/alihbase-thrift

@Override
public boolean removeAll(Collection<?> elements) {
 return underlyingQueue.removeAll(elements);
}

代码示例来源:origin: co.cask.hbase/hbase

@Override
public boolean removeAll(Collection<?> elements) {
 return underlyingQueue.removeAll(elements);
}

代码示例来源:origin: org.apache.hbase/hbase-thrift

@Override
public boolean removeAll(Collection<?> elements) {
 return underlyingQueue.removeAll(elements);
}

代码示例来源:origin: out0fmemory/GuozhongCrawler

public boolean removeAll(final Collection<?> c) {
  return queue.removeAll(c);
}

代码示例来源:origin: com.github.rholder/moar-concurrent

public boolean removeAll(Collection<?> c) {
  return blockingQueue.removeAll(c);
}

代码示例来源:origin: org.terracotta/product-upgradability-testing-utils

public boolean removeAll(Collection<?> c) {
 Lock l = lock.writeLock();
 l.lock();
 try {
 return backing.removeAll(c);
 } finally {
  l.unlock();
 }
}

代码示例来源:origin: net.sf.jabb/jabb-core

@Override
public boolean removeAll(Collection<?> c) {
  boolean b = queue.removeAll(c);
  if (b){
    signalSizeReduced();
  }
  return b;
}

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

public boolean removeAll(Collection<?> c) {
 if (isRunning()) {
  return q.removeAll(c);
 }
 else {
  return false;
 }
}

代码示例来源:origin: org.opendaylight.aaa/aaa-authn

@Override
public boolean removeAll(Collection<?> c) {
  return queue.removeAll(fromData(c));
}

相关文章