1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28 package org.apache.hc.client5.http.impl;
29
30 import java.util.concurrent.ThreadFactory;
31
32 import org.apache.hc.core5.annotation.Contract;
33 import org.apache.hc.core5.annotation.ThreadingBehavior;
34 import org.apache.hc.core5.concurrent.DefaultThreadFactory;
35 import org.apache.hc.core5.pool.ConnPoolControl;
36 import org.apache.hc.core5.util.Args;
37 import org.apache.hc.core5.util.TimeValue;
38 import org.apache.hc.core5.util.Timeout;
39
40
41
42
43
44
45
46 @Contract(threading = ThreadingBehavior.SAFE_CONDITIONAL)
47 public final class IdleConnectionEvictor {
48
49 private final ThreadFactory threadFactory;
50 private final Thread thread;
51
52 public IdleConnectionEvictor(final ConnPoolControl<?> connectionManager, final ThreadFactory threadFactory,
53 final TimeValue sleepTime, final TimeValue maxIdleTime) {
54 Args.notNull(connectionManager, "Connection manager");
55 this.threadFactory = threadFactory != null ? threadFactory : new DefaultThreadFactory("idle-connection-evictor", true);
56 final TimeValue localSleepTime = sleepTime != null ? sleepTime : TimeValue.ofSeconds(5);
57 this.thread = this.threadFactory.newThread(() -> {
58 try {
59 while (!Thread.currentThread().isInterrupted()) {
60 localSleepTime.sleep();
61 connectionManager.closeExpired();
62 if (maxIdleTime != null) {
63 connectionManager.closeIdle(maxIdleTime);
64 }
65 }
66 } catch (final InterruptedException ex) {
67 Thread.currentThread().interrupt();
68 } catch (final Exception ex) {
69 }
70
71 });
72 }
73
74 public IdleConnectionEvictor(final ConnPoolControl<?> connectionManager, final TimeValue sleepTime, final TimeValue maxIdleTime) {
75 this(connectionManager, null, sleepTime, maxIdleTime);
76 }
77
78 public IdleConnectionEvictor(final ConnPoolControl<?> connectionManager, final TimeValue maxIdleTime) {
79 this(connectionManager, null, maxIdleTime, maxIdleTime);
80 }
81
82 public void start() {
83 thread.start();
84 }
85
86 public void shutdown() {
87 thread.interrupt();
88 }
89
90 public boolean isRunning() {
91 return thread.isAlive();
92 }
93
94 public void awaitTermination(final Timeout timeout) throws InterruptedException {
95 thread.join(timeout != null ? timeout.toMilliseconds() : Long.MAX_VALUE);
96 }
97
98 }