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(new Runnable() {
58 @Override
59 public void run() {
60 try {
61 while (!Thread.currentThread().isInterrupted()) {
62 localSleepTime.sleep();
63 connectionManager.closeExpired();
64 if (maxIdleTime != null) {
65 connectionManager.closeIdle(maxIdleTime);
66 }
67 }
68 } catch (final InterruptedException ex) {
69 Thread.currentThread().interrupt();
70 } catch (final Exception ex) {
71 }
72
73 }
74 });
75 }
76
77 public IdleConnectionEvictor(final ConnPoolControl<?> connectionManager, final TimeValue sleepTime, final TimeValue maxIdleTime) {
78 this(connectionManager, null, sleepTime, maxIdleTime);
79 }
80
81 public IdleConnectionEvictor(final ConnPoolControl<?> connectionManager, final TimeValue maxIdleTime) {
82 this(connectionManager, null, maxIdleTime, maxIdleTime);
83 }
84
85 public void start() {
86 thread.start();
87 }
88
89 public void shutdown() {
90 thread.interrupt();
91 }
92
93 public boolean isRunning() {
94 return thread.isAlive();
95 }
96
97 public void awaitTermination(final Timeout timeout) throws InterruptedException {
98 thread.join(timeout != null ? timeout.toMilliseconds() : Long.MAX_VALUE);
99 }
100
101 }