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

TransportService.getExecutorService介绍

[英]The executor service for this transport service.
[中]此传输服务的执行者服务。

代码示例

代码示例来源：origin: org.elasticsearch/elasticsearch

getExecutorService().execute(new AbstractRunnable() {
  @Override
  public void onRejection(Exception e) {

代码示例来源：origin: org.elasticsearch/elasticsearch

@Override
public void onConnectionClosed(Transport.Connection connection) {
  try {
    List<Transport.ResponseContext<? extends TransportResponse>> pruned =
      responseHandlers.prune(h -> h.connection().getCacheKey().equals(connection.getCacheKey()));
    // callback that an exception happened, but on a different thread since we don't
    // want handlers to worry about stack overflows
    getExecutorService().execute(() -> {
      for (Transport.ResponseContext holderToNotify : pruned) {
        holderToNotify.handler().handleException(new NodeDisconnectedException(connection.getNode(), holderToNotify.action()));
      }
    });
  } catch (EsRejectedExecutionException ex) {
    logger.debug("Rejected execution on onConnectionClosed", ex);
  }
}

代码示例来源：origin: com.strapdata.elasticsearch.test/framework

@Override
protected ExecutorService getExecutorService() {
  return executorName == null ? super.getExecutorService() : getThreadPool().executor(executorName);
}

代码示例来源：origin: org.apache.servicemix.bundles/org.apache.servicemix.bundles.elasticsearch

getExecutorService().execute(new AbstractRunnable() {
  @Override
  public void onRejection(Exception e) {

代码示例来源：origin: org.apache.servicemix.bundles/org.apache.servicemix.bundles.elasticsearch

@Override
public void onConnectionClosed(Transport.Connection connection) {
  try {
    List<Transport.ResponseContext> pruned = responseHandlers.prune(h -> h.connection().getCacheKey().equals(connection
      .getCacheKey()));
    // callback that an exception happened, but on a different thread since we don't
    // want handlers to worry about stack overflows
    getExecutorService().execute(() -> {
      for (Transport.ResponseContext holderToNotify : pruned) {
        holderToNotify.handler().handleException(new NodeDisconnectedException(connection.getNode(), holderToNotify.action()));
      }
    });
  } catch (EsRejectedExecutionException ex) {
    logger.debug("Rejected execution on onConnectionClosed", ex);
  }
}