本文整理了Java中okhttp3.ConnectionPool.evictAll()
方法的一些代码示例,展示了ConnectionPool.evictAll()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。ConnectionPool.evictAll()
方法的具体详情如下:
包路径:okhttp3.ConnectionPool
类名称: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();
}
}
内容来源于网络,如有侵权,请联系作者删除!