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

Client.threadPool介绍

暂无

代码示例

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

/**
 * Creates a new FilterClient
 *
 * @param in the client to delegate to
 * @see #in()
 */
public FilterClient(Client in) {
  this(in.settings(), in.threadPool(), in);
}

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

public static Builder builder(Client client, Listener listener) {
  Objects.requireNonNull(client, "client");
  Objects.requireNonNull(listener, "listener");
  return new Builder(client::bulk, listener, client.threadPool(), () -> {});
}

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

@Override
  protected <
        Request extends ActionRequest,
        Response extends ActionResponse,
        RequestBuilder extends ActionRequestBuilder<Request, Response, RequestBuilder>>
      void doExecute(
        Action<Request, Response, RequestBuilder> action,
        Request request,
        ActionListener<Response> listener) {
    final Supplier<ThreadContext.StoredContext> supplier = in().threadPool().getThreadContext().newRestorableContext(false);
    try (ThreadContext.StoredContext ignore = in().threadPool().getThreadContext().stashWithOrigin(origin)) {
      super.doExecute(action, request, new ContextPreservingActionListener<>(supplier, listener));
    }
  }
}

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

public static Builder builder(Client client, Listener listener) {
  Objects.requireNonNull(client, "client");
  Objects.requireNonNull(listener, "listener");
  return new Builder(client::bulk, listener, client.threadPool(), () -> {});
}

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

/**
 * Creates a new FilterClient
 *
 * @param in the client to delegate to
 * @see #in()
 */
public FilterClient(Client in) {
  this(in.settings(), in.threadPool(), in);
}

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

/**
 * Creates a new FilterClient
 *
 * @param in the client to delegate to
 * @see #in()
 */
public FilterClient(Client in) {
  this(in.settings(), in.threadPool(), in);
}

代码示例来源：origin: apache/servicemix-bundles

public static Builder builder(Client client, Listener listener) {
  Objects.requireNonNull(client, "client");
  Objects.requireNonNull(listener, "listener");
  return new Builder(client::bulk, listener, client.threadPool(), () -> {});
}

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

private void retry(BulkRequest bulkRequestForRetry) {
  assert backoff.hasNext();
  TimeValue next = backoff.next();
  logger.trace("Retry of bulk request scheduled in {} ms.", next.millis());
  Runnable retry = () -> this.execute(bulkRequestForRetry);
  retry = client.threadPool().getThreadContext().preserveContext(retry);
  scheduledRequestFuture = client.threadPool().schedule(next, ThreadPool.Names.SAME, retry);
}

代码示例来源：origin: harbby/presto-connectors

private void retry(final BulkRequest bulkRequestForRetry) {
  assert backoff.hasNext();
  TimeValue next = backoff.next();
  logger.trace("Retry of bulk request scheduled in {} ms.", next.millis());
  scheduledRequestFuture = client.threadPool().schedule(next, ThreadPool.Names.SAME, new Runnable() {
    @Override
    public void run() {
      AbstractRetryHandler.this.execute(bulkRequestForRetry);
    }
  });
}

代码示例来源：origin: harbby/presto-connectors

/**
 * Creates a new FilterClient
 *
 * @param in the client to delegate to
 * @see #in()
 */
public FilterClient(Client in) {
  super(in.settings(), in.threadPool(), in.headers());
  this.in = in;
}

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

/**
 * Cancels a locally running task using the Task Manager API
 */
void sendCancelRequest(final long taskId, final String reason, final ActionListener<CancelTasksResponse> listener) {
  CancelTasksRequest request = new CancelTasksRequest();
  request.setTaskId(new TaskId(clusterService.localNode().getId(), taskId));
  request.setReason(reason);
  try {
    final ThreadContext threadContext = client.threadPool().getThreadContext();
    final Supplier<ThreadContext.StoredContext> supplier = threadContext.newRestorableContext(false);
    try (ThreadContext.StoredContext ignore = stashWithOrigin(threadContext, PERSISTENT_TASK_ORIGIN)) {
      client.admin().cluster().cancelTasks(request, new ContextPreservingActionListener<>(supplier, listener));
    }
  } catch (Exception e) {
    listener.onFailure(e);
  }
}

代码示例来源：origin: apache/servicemix-bundles

/**
 * Cancels a locally running task using the Task Manager API
 */
void sendCancelRequest(final long taskId, final String reason, final ActionListener<CancelTasksResponse> listener) {
  CancelTasksRequest request = new CancelTasksRequest();
  request.setTaskId(new TaskId(clusterService.localNode().getId(), taskId));
  request.setReason(reason);
  try {
    final ThreadContext threadContext = client.threadPool().getThreadContext();
    final Supplier<ThreadContext.StoredContext> supplier = threadContext.newRestorableContext(false);
    try (ThreadContext.StoredContext ignore = stashWithOrigin(threadContext, PERSISTENT_TASK_ORIGIN)) {
      client.admin().cluster().cancelTasks(request, new ContextPreservingActionListener<>(supplier, listener));
    }
  } catch (Exception e) {
    listener.onFailure(e);
  }
}

代码示例来源：origin: apache/servicemix-bundles

/**
 * Executes an asynchronous persistent task action using the client.
 * <p>
 * The origin is set in the context and the listener is wrapped to ensure the proper context is restored
 */
private <Req extends ActionRequest, Resp extends PersistentTaskResponse, Builder extends ActionRequestBuilder<Req, Resp, Builder>>
  void execute(final Req request, final Action<Req, Resp, Builder> action, final ActionListener<PersistentTask<?>> listener) {
    try {
      final ThreadContext threadContext = client.threadPool().getThreadContext();
      final Supplier<ThreadContext.StoredContext> supplier = threadContext.newRestorableContext(false);
      try (ThreadContext.StoredContext ignore = stashWithOrigin(threadContext, PERSISTENT_TASK_ORIGIN)) {
        client.execute(action, request,
          new ContextPreservingActionListener<>(supplier,
            ActionListener.wrap(r -> listener.onResponse(r.getTask()), listener::onFailure)));
      }
    } catch (Exception e) {
      listener.onFailure(e);
    }
}

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

/**
 * Executes an asynchronous persistent task action using the client.
 * <p>
 * The origin is set in the context and the listener is wrapped to ensure the proper context is restored
 */
private <Req extends ActionRequest, Resp extends PersistentTaskResponse, Builder extends ActionRequestBuilder<Req, Resp, Builder>>
  void execute(final Req request, final Action<Req, Resp, Builder> action, final ActionListener<PersistentTask<?>> listener) {
    try {
      final ThreadContext threadContext = client.threadPool().getThreadContext();
      final Supplier<ThreadContext.StoredContext> supplier = threadContext.newRestorableContext(false);
      try (ThreadContext.StoredContext ignore = stashWithOrigin(threadContext, PERSISTENT_TASK_ORIGIN)) {
        client.execute(action, request,
          new ContextPreservingActionListener<>(supplier,
            ActionListener.wrap(r -> listener.onResponse(r.getTask()), listener::onFailure)));
      }
    } catch (Exception e) {
      listener.onFailure(e);
    }
}