javax.ws.rs.client.ClientBuilder.executorService()方法的使用及代码示例

x33g5p2x  于2022-01-18 转载在 其他  
字(2.8k)|赞(0)|评价(0)|浏览(121)

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

ClientBuilder.executorService介绍

[英]Set the client-side ExecutorService.

Provided executor service will be used for executing asynchronous tasks.

When running in a Java EE container, implementations are required to use the container-managed executor service by default. In Java SE, the default is implementation-specific. In either case, calling this method will override the default.
[中]设置客户端Executor服务。
提供的执行器服务将用于执行异步任务。
在JavaEE容器中运行时,默认情况下,实现需要使用容器管理的执行器服务。在JavaSE中,默认值是特定于实现的。在任何一种情况下,调用此方法都将覆盖默认值。

代码示例

代码示例来源:origin: org.apache.geronimo/geronimo-opentracing-common

@Override
public ClientBuilder configure(final ClientBuilder builder, final ExecutorService executorService) {
  if (builder.getConfiguration().getInstances().stream().anyMatch(it -> requestFilter == it)) {
    return builder;
  }
  return builder.register(requestFilter).register(responseFilter)
      .executorService(wrapExecutor(executorService));
}

代码示例来源:origin: org.talend.sdk.component/component-server-vault-proxy

private ClientBuilder createClient(final ExecutorService executor, final Optional<String> keystoreLocation,
    final Optional<String> keystoreType, final String keystorePassword, final Optional<String> truststoreType,
    final List<String> serverHostnames) {
  final ClientBuilder builder = ClientBuilder.newBuilder();
  builder.connectTimeout(connectTimeout, MILLISECONDS);
  builder.readTimeout(readTimeout, MILLISECONDS);
  builder.executorService(executor);
  if (acceptAnyCertificate) {
    builder.hostnameVerifier((host, session) -> true);
    builder.sslContext(createUnsafeSSLContext());
  } else if (keystoreLocation.isPresent()) {
    builder.hostnameVerifier((host, session) -> serverHostnames.contains(host));
    builder.sslContext(createSSLContext(keystoreLocation, keystoreType, keystorePassword, truststoreType));
  }
  providers
      .map(it -> Stream.of(it.split(",")).map(String::trim).filter(v -> !v.isEmpty()))
      .ifPresent(it -> it.forEach(builder::register));
  return ClientTracingRegistrar.configure(builder);
}

代码示例来源:origin: org.talend.sdk.component/component-server-proxy

@Produces
@UiSpecProxy
@ApplicationScoped
public javax.ws.rs.client.Client client(final ProxyConfiguration configuration,
    @UiSpecProxy final ExecutorService executor) {
  final javax.ws.rs.client.Client client = ClientBuilder
      .newBuilder()
      .executorService(executor)
      .property("executorService", executor) // rx()
      .connectTimeout(configuration.getConnectTimeout(), MILLISECONDS)
      .readTimeout(configuration.getReadTimeout(), MILLISECONDS)
      .build();
  ofNullable(configuration.getClientProviders()).ifPresent(list -> list.forEach(client::register));
  return client;
}

相关文章