okhttp3.ConnectionPool.evictAll()方法的使用及代码示例

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

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

ConnectionPool.evictAll介绍

[英]Close and remove all idle connections in the pool.
[中]关闭并删除池中的所有空闲连接。

代码示例

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

private void close() {
 client.connectionPool().evictAll(); // Close any persistent connections.
}

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

private static void testClient(List<String> urls, OkHttpClient client) {
 try {
  for (String url : urls) {
   sendRequest(client, url);
  }
 } finally {
  client.dispatcher.executorService().shutdownNow();
  client.connectionPool.evictAll();
 }
}

代码示例来源:origin: googlemaps/google-maps-services-java

@Override
public void shutdown() {
 executorService.shutdown();
 client.connectionPool().evictAll();
}

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

@Override
public void close()
{
  httpClient.dispatcher().executorService().shutdown();
  httpClient.connectionPool().evictAll();
}

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

@Override
public void close()
{
  httpClient.dispatcher().executorService().shutdown();
  httpClient.connectionPool().evictAll();
}

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

public void close() {
  client.dispatcher().executorService().shutdown();
  client.connectionPool().evictAll();
}

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

httpClient.connectionPool().evictAll();

代码示例来源:origin: fabric8io/kubernetes-client

public static boolean isHttpsAvailable(Config config) {
  Config sslConfig = new ConfigBuilder(config)
      .withMasterUrl(Config.HTTPS_PROTOCOL_PREFIX + config.getMasterUrl())
      .withRequestTimeout(1000)
      .withConnectionTimeout(1000)
      .build();
  OkHttpClient client = HttpClientUtils.createHttpClient(config);
  try {
    Request request = new Request.Builder().get().url(sslConfig.getMasterUrl())
        .build();
    Response response = client.newCall(request).execute();
    try (ResponseBody body = response.body()) {
     return response.isSuccessful();
    }
  } catch (Throwable t) {
    LOG.warn("SSL handshake failed. Falling back to insecure connection.");
  } finally {
    if (client != null && client.connectionPool() != null) {
      client.connectionPool().evictAll();
    }
  }
  return false;
}

代码示例来源:origin: fabric8io/kubernetes-client

@Override
public void close() {
 ConnectionPool connectionPool = httpClient.connectionPool();
 Dispatcher dispatcher = httpClient.dispatcher();
 ExecutorService executorService = httpClient.dispatcher() != null ? httpClient.dispatcher().executorService() : null;
 if (dispatcher != null) {
  dispatcher.cancelAll();
 }
 if (connectionPool != null) {
  connectionPool.evictAll();
 }
 Utils.shutdownExecutorService(executorService);
}

代码示例来源:origin: com.google.maps/google-maps-services

@Override
public void shutdown() {
 executorService.shutdown();
 client.connectionPool().evictAll();
}

代码示例来源:origin: org.springframework.cloud/spring-cloud-openfeign-core

@PreDestroy
public void destroy() {
  if(okHttpClient != null) {
    okHttpClient.dispatcher().executorService().shutdown();
    okHttpClient.connectionPool().evictAll();
  }
}

代码示例来源:origin: spring-cloud/spring-cloud-openfeign

@PreDestroy
  public void destroy() {
    if(okHttpClient != null) {
      okHttpClient.dispatcher().executorService().shutdown();
      okHttpClient.connectionPool().evictAll();
    }
  }
}

代码示例来源:origin: com.couchbase.lite/couchbase-lite-java-core

@Override
@InterfaceAudience.Private
public void evictAllConnectionsInPool() {
  if (client != null) {
    ConnectionPool pool = client.connectionPool();
    if (pool != null)
      pool.evictAll();
  }
}

代码示例来源:origin: com.github.mjeanroy/junit-servers-core

@Override
public void destroy() {
  if (destroyed.compareAndSet(false, true)) {
    client.dispatcher().executorService().shutdown();
    client.connectionPool().evictAll();
  }
}

代码示例来源:origin: spring-cloud/spring-cloud-openfeign

@PreDestroy
public void destroy() {
  if(okHttpClient != null) {
    okHttpClient.dispatcher().executorService().shutdown();
    okHttpClient.connectionPool().evictAll();
  }
}

代码示例来源:origin: org.springframework.cloud/spring-cloud-netflix-ribbon

@PreDestroy
  public void destroy() {
    if(httpClient != null) {
      httpClient.dispatcher().executorService().shutdown();
      httpClient.connectionPool().evictAll();
    }
  }
}

代码示例来源:origin: spotify/styx

@Override
 public void close() {
  client.connectionPool().evictAll();
  client.dispatcher().executorService().shutdown();
 }
}

代码示例来源:origin: com.facebook.presto/presto-tests

@Override
public void close()
{
  httpClient.dispatcher().executorService().shutdown();
  httpClient.connectionPool().evictAll();
}

代码示例来源:origin: com.facebook.presto/presto-cli

@Override
public void close()
{
  httpClient.dispatcher().executorService().shutdown();
  httpClient.connectionPool().evictAll();
}

代码示例来源:origin: com.pubnub/pubnub-gson

private void closeExecutor(OkHttpClient client, boolean force) {
  client.dispatcher().cancelAll();
  if (force) {
    client.connectionPool().evictAll();
    ExecutorService executorService = client.dispatcher().executorService();
    executorService.shutdown();
  }
}

相关文章