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 package org.apache.hc.client5.http.impl.classic;
28
29 import java.util.concurrent.FutureTask;
30
31 import org.apache.hc.core5.concurrent.Cancellable;
32 import org.apache.hc.core5.http.ClassicHttpRequest;
33
34 final class HttpRequestFutureTask<V> extends FutureTask<V> {
35
36 private final ClassicHttpRequest request;
37 private final HttpRequestTaskCallable<V> callable;
38
39 HttpRequestFutureTask(
40 final ClassicHttpRequest request,
41 final HttpRequestTaskCallable<V> httpCallable) {
42 super(httpCallable);
43 this.request = request;
44 this.callable = httpCallable;
45 }
46
47 @Override
48 public boolean cancel(final boolean mayInterruptIfRunning) {
49 callable.cancel();
50 if (mayInterruptIfRunning && request instanceof Cancellable) {
51 ((Cancellable) request).cancel();
52 }
53 return super.cancel(mayInterruptIfRunning);
54 }
55
56
57
58
59 public long scheduledTime() {
60 return callable.getScheduled();
61 }
62
63
64
65
66 public long startedTime() {
67 return callable.getStarted();
68 }
69
70
71
72
73 public long endedTime() {
74 if (isDone()) {
75 return callable.getEnded();
76 } else {
77 throw new IllegalStateException("Task is not done yet");
78 }
79 }
80
81
82
83
84
85 public long requestDuration() {
86 if (isDone()) {
87 return endedTime() - startedTime();
88 } else {
89 throw new IllegalStateException("Task is not done yet");
90 }
91 }
92
93
94
95
96 public long taskDuration() {
97 if (isDone()) {
98 return endedTime() - scheduledTime();
99 } else {
100 throw new IllegalStateException("Task is not done yet");
101 }
102 }
103
104 @Override
105 public String toString() {
106 return request.toString();
107 }
108
109 }