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

LinkedBlockingQueue.add介绍

暂无

代码示例

代码示例来源：origin: code4craft/webmagic

public void release(ScriptEngine scriptEngine){
  scriptEngines.add(scriptEngine);
  availableCount.incrementAndGet();
}

代码示例来源：origin: ReactiveX/RxJava

@Override
public void onError(Throwable e) {
  events.add(TestConcurrencySubscriberEvent.onError);
}

代码示例来源：origin: ReactiveX/RxJava

@Override
public void onComplete() {
  events.add(TestConcurrencySubscriberEvent.onComplete);
}

代码示例来源：origin: ReactiveX/RxJava

@Override
public void onComplete() {
  events.add(TestConcurrencySubscriberEvent.onComplete);
}

代码示例来源：origin: ReactiveX/RxJava

@Override
public void onError(Throwable e) {
  events.add(TestConcurrencySubscriberEvent.onError);
}

代码示例来源：origin: prestodb/presto

public void failed(Throwable cause)
{
  failureCauses.add(cause);
  transitionToDoneState(TaskState.FAILED);
}

代码示例来源：origin: code4craft/webmagic

public ScriptEnginePool(Language language,int size) {
  this.size = size;
  this.availableCount = new AtomicInteger(size);
  for (int i=0;i<size;i++){
    ScriptEngineManager manager = new ScriptEngineManager();
    ScriptEngine engine = manager.getEngineByName(language.getEngineName());
    scriptEngines.add(engine);
  }
}

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

@Override
  public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
    received.add((ByteBuf) msg);
  }
});

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

@Override
  public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
    received.add((ByteBuf) msg);
  }
});

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

@Override
public void onWebSocketClose( int i, String s )
{
  received.add( POISON_PILL );
}

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

public void commit(Request request) {
  if (stopped || request == null) {
    return;
  }
  if (LOG.isDebugEnabled()) {
    LOG.debug("Committing request:: " + request);
  }
  committedRequests.add(request);
  wakeup();
}

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

@Override
public void processRequest(Request request) {
  if (stopped) {
    return;
  }
  if (LOG.isDebugEnabled()) {
    LOG.debug("Processing request:: " + request);
  }
  queuedRequests.add(request);
  wakeup();
}

代码示例来源：origin: ReactiveX/RxJava

@Override
public void onNext(String args) {
  events.add(TestConcurrencySubscriberEvent.onNext);
  // do some artificial work to make the thread scheduling/timing vary
  int s = 0;
  for (int i = 0; i < 20; i++) {
    s += s * i;
  }
  if (waitTime > 0) {
    try {
      Thread.sleep(waitTime);
    } catch (InterruptedException e) {
      // ignore
    }
  }
}

代码示例来源：origin: ReactiveX/RxJava

@Override
public void onNext(String args) {
  events.add(TestConcurrencySubscriberEvent.onNext);
  // do some artificial work to make the thread scheduling/timing vary
  int s = 0;
  for (int i = 0; i < 20; i++) {
    s += s * i;
  }
  if (waitTime > 0) {
    try {
      Thread.sleep(waitTime);
    } catch (InterruptedException e) {
      // ignore
    }
  }
}

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

public void putNettyEvent(final NettyEvent event) {
  if (this.eventQueue.size() <= maxSize) {
    this.eventQueue.add(event);
  } else {
    log.warn("event queue size[{}] enough, so drop this event {}", this.eventQueue.size(), event.toString());
  }
}

代码示例来源：origin: square/okhttp

public static void main(String[] args) throws IOException {
  if (args.length != 2) {
   System.out.println("Usage: Crawler <cache dir> <root>");
   return;
  }

  int threadCount = 20;
  long cacheByteCount = 1024L * 1024L * 100L;

  Cache cache = new Cache(new File(args[0]), cacheByteCount);
  OkHttpClient client = new OkHttpClient.Builder()
    .cache(cache)
    .build();

  Crawler crawler = new Crawler(client);
  crawler.queue.add(HttpUrl.get(args[1]));
  crawler.parallelDrainQueue(threadCount);
 }
}

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

public void shutdown() {
  LOG.info("Shutting down");
  finished = true;
  queuedRequests.clear();
  queuedRequests.add(Request.requestOfDeath);
  nextProcessor.shutdown();
}

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

/**
 * Shutdown the processor.
 */
public void shutdown() {
  LOG.info("Shutting down");
  finished = true;
  queuedRequests.clear();
  queuedRequests.add(Request.requestOfDeath);
  nextProcessor.shutdown();
}

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

public void shutdown() {
    LOG.info("Shutting down");
    submittedRequests.clear();
    submittedRequests.add(Request.requestOfDeath);
    nextProcessor.shutdown();
  }
}

代码示例来源：origin: prestodb/presto

synchronized void addSplits(int count)
{
  if (closed) {
    return;
  }
  for (int i = 0; i < count; i++) {
    queue.add(splitFactory.get());
    notEmptyFuture.complete(null);
  }
}