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

AsyncHttpClientConfig.executorService介绍

[英]Return the java.util.concurrent.ExecutorService an AsyncHttpClient use for handling asynchronous response.
[中]返回java。util。同时发生的ExecutorService异步HttpClient用于处理异步响应。

代码示例

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

/**
 * Submits the response processing on Grizzly client's application thread pool.
 *
 * @param responseTask task to be processed on application thread pool.
 */
private void processResponse(Runnable responseTask) {
  this.grizzlyClient.getConfig().executorService().submit(responseTask);
}

代码示例来源：origin: com.ning/async-http-client

public void close() {
  if (closed.compareAndSet(false, true)) {
    try {
      channelManager.close();
      // FIXME shouldn't close if not allowed
      config.executorService().shutdown();
      if (allowStopNettyTimer)
        nettyTimer.stop();
    } catch (Throwable t) {
      LOGGER.warn("Unexpected error on close", t);
    }
  }
}

代码示例来源：origin: com.ning/async-http-client

@Override
public void close() {
  try {
    connectionManager.destroy();
    clientTransport.shutdownNow();
    final ExecutorService service = clientConfig.executorService();
    if (service != null) {
      service.shutdown();
    }
    if (timeoutExecutor != null) {
      timeoutExecutor.stop();
      timeoutExecutor.getThreadPool().shutdownNow();
    }
  } catch (IOException ignored) { }
}

代码示例来源：origin: com.ning/async-http-client

private void doDefaultTransportConfig() {
  final ExecutorService service = clientConfig.executorService();
  if (service != null) {
    clientTransport.setIOStrategy(WorkerThreadIOStrategy.getInstance());
    clientTransport.setWorkerThreadPool(service);
  } else {
    clientTransport.setIOStrategy(SameThreadIOStrategy.getInstance());
  }
}

代码示例来源：origin: com.ning/async-http-client

f.touch();
f.setInnerFuture(config.executorService().submit(new AsyncHttpUrlConnection(urlConnection, request, handler, f)));
maxConnections.incrementAndGet();

代码示例来源：origin: com.ning/async-http-client

public void close() {
  channelPool.destroy();
  openChannels.close();
  for (Channel channel : openChannels) {
    Object attribute = Channels.getAttribute(channel);
    if (attribute instanceof NettyResponseFuture<?>) {
      NettyResponseFuture<?> future = (NettyResponseFuture<?>) attribute;
      future.cancelTimeouts();
    }
  }
  // FIXME also shutdown in provider
  config.executorService().shutdown();
  if (allowReleaseSocketChannelFactory) {
    socketChannelFactory.releaseExternalResources();
    plainBootstrap.releaseExternalResources();
    secureBootstrap.releaseExternalResources();
    webSocketBootstrap.releaseExternalResources();
    secureWebSocketBootstrap.releaseExternalResources();
  }
}

代码示例来源：origin: com.ning/async-http-client

followRedirect = prototype.isFollowRedirect();
compressionEnforced = prototype.isCompressionEnforced();
applicationThreadPool = prototype.executorService();

代码示例来源：origin: com.ning/async-http-client

int numWorkers = config.getIoThreadMultiplier() * Runtime.getRuntime().availableProcessors();
LOGGER.trace("Number of application's worker threads is {}", numWorkers);
socketChannelFactory = new NioClientSocketChannelFactory(e, config.executorService(), numWorkers);
allowReleaseSocketChannelFactory = true;

代码示例来源：origin: org.glassfish.jersey.connectors/jersey-grizzly-connector

/**
 * Submits the response processing on Grizzly client's application thread pool.
 *
 * @param responseTask task to be processed on application thread pool.
 */
private void processResponse(Runnable responseTask) {
  this.grizzlyClient.getConfig().executorService().submit(responseTask);
}

代码示例来源：origin: io.gatling/async-http-client

public void close() {
  if (closed.compareAndSet(false, true)) {
    try {
      channelManager.close();
      // FIXME shouldn't close if not allowed
      config.executorService().shutdown();
      if (allowStopNettyTimer)
        nettyTimer.stop();
    } catch (Throwable t) {
      LOGGER.warn("Unexpected error on close", t);
    }
  }
}

代码示例来源：origin: org.glassfish.grizzly/grizzly-http-client

@Override
public void close() {
  try {
    connectionManager.destroy();
    clientTransport.shutdownNow();
    final ExecutorService service = clientConfig.executorService();
    if (service != null) {
      service.shutdown();
    }
    if (timeoutExecutor != null) {
      timeoutExecutor.stop();
      timeoutExecutor.getThreadPool().shutdownNow();
    }
  } catch (IOException ignored) { }
}

代码示例来源：origin: io.gatling/async-http-client

@Override
public void close() {
  try {
    connectionManager.destroy();
    clientTransport.shutdownNow();
    final ExecutorService service = clientConfig.executorService();
    if (service != null) {
      service.shutdown();
    }
    if (timeoutExecutor != null) {
      timeoutExecutor.stop();
      timeoutExecutor.getThreadPool().shutdownNow();
    }
  } catch (IOException ignored) { }
}

代码示例来源：origin: javaee/grizzly-ahc

@Override
public void close() {
  try {
    connectionManager.destroy();
    clientTransport.shutdownNow();
    final ExecutorService service = clientConfig.executorService();
    if (service != null) {
      service.shutdown();
    }
    if (timeoutExecutor != null) {
      timeoutExecutor.stop();
      timeoutExecutor.getThreadPool().shutdownNow();
    }
  } catch (IOException ignored) { }
}

代码示例来源：origin: org.glassfish.grizzly/grizzly-http-client

private void doDefaultTransportConfig() {
  final ExecutorService service = clientConfig.executorService();
  if (service != null) {
    clientTransport.setIOStrategy(WorkerThreadIOStrategy.getInstance());
    clientTransport.setWorkerThreadPool(service);
  } else {
    clientTransport.setIOStrategy(SameThreadIOStrategy.getInstance());
  }
}

代码示例来源：origin: sonatype/sonatype-aether

handleResponseCode( uri, response.getStatusCode(), response.getStatusText() );
httpClient.getConfig().executorService().execute( new Runnable()

代码示例来源：origin: javaee/grizzly-ahc

private void doDefaultTransportConfig() {
  final ExecutorService service = clientConfig.executorService();
  if (service != null) {
    clientTransport.setIOStrategy(WorkerThreadIOStrategy.getInstance());
    clientTransport.setWorkerThreadPool(service);
  } else {
    clientTransport.setIOStrategy(SameThreadIOStrategy.getInstance());
  }
}

代码示例来源：origin: org.sonatype.aether/aether-connector-asynchttpclient

handleResponseCode( uri, response.getStatusCode(), response.getStatusText() );
httpClient.getConfig().executorService().execute( new Runnable()

代码示例来源：origin: io.gatling/async-http-client

private void doDefaultTransportConfig() {
  final ExecutorService service = clientConfig.executorService();
  if (service != null) {
    clientTransport.setIOStrategy(WorkerThreadIOStrategy.getInstance());
    clientTransport.setWorkerThreadPool(service);
  } else {
    clientTransport.setIOStrategy(SameThreadIOStrategy.getInstance());
  }
}

代码示例来源：origin: io.gatling/async-http-client

public void close() {
  channelPool.destroy();
  openChannels.close();
  for (Channel channel : openChannels) {
    Object attribute = Channels.getAttribute(channel);
    if (attribute instanceof NettyResponseFuture<?>) {
      NettyResponseFuture<?> future = (NettyResponseFuture<?>) attribute;
      future.cancelTimeouts();
    }
  }
  // FIXME also shutdown in provider
  config.executorService().shutdown();
  if (allowReleaseSocketChannelFactory) {
    socketChannelFactory.releaseExternalResources();
    plainBootstrap.releaseExternalResources();
    secureBootstrap.releaseExternalResources();
    webSocketBootstrap.releaseExternalResources();
    secureWebSocketBootstrap.releaseExternalResources();
  }
}

代码示例来源：origin: io.gatling/async-http-client

f.touch();
f.setInnerFuture(config.executorService().submit(new ApacheClientRunnable(request, handler, method, f, httpClient)));
maxConnections.incrementAndGet();
return f;