Skip to content

Commit c272d7a

Browse files
jentfoojentfoo
committed
Update ListenableFutureTaskMicro off deprecated API's
1 parent 1e12214 commit c272d7a

File tree

1 file changed

+30
-25
lines changed

1 file changed

+30
-25
lines changed

‎src/main/java/org/threadly/concurrent/benchmark/jmh/ListenableFutureTaskMicro.java

+30-25
Original file line numberDiff line numberDiff line change
@@ -34,20 +34,25 @@ public class ListenableFutureTaskMicro extends AbstractListenableFutureMicro {
3434
SCHEDULER = new SingleThreadScheduler();
3535
SCHEDULER.prestartExecutionThread();
3636

37-
TASK_DONE_WITH_RESULT = new ListenableFutureTask<>(false, DoNothingRunnable.instance());
37+
TASK_DONE_WITH_RESULT = new ListenableFutureTask<>(DoNothingRunnable.instance());
3838
TASK_DONE_WITH_RESULT.run();
39-
TASK_DONE_WITH_FAILURE = new ListenableFutureTask<>(false, THROWING_CALLABLE);
39+
TASK_DONE_WITH_FAILURE = new ListenableFutureTask<>(THROWING_CALLABLE);
4040
TASK_DONE_WITH_FAILURE.run();
4141
}
4242

4343
@Benchmark
44-
public void constructRun_direct() {
45-
new ListenableFutureTask<Void>(false, DoNothingRunnable.instance()).run();
44+
public void constructRun_directResult() {
45+
new ListenableFutureTask<Void>(DoNothingRunnable.instance()).run();
46+
}
47+
48+
@Benchmark
49+
public void constructRun_directFailure() {
50+
new ListenableFutureTask<>(THROWING_CALLABLE).run();
4651
}
4752

4853
@Benchmark
4954
public void constructRun_singleThreadSchedulerSubmitAndGet() throws InterruptedException, ExecutionException {
50-
ListenableFutureTask<Void> lft = new ListenableFutureTask<Void>(false, DoNothingRunnable.instance());
55+
ListenableFutureTask<Void> lft = new ListenableFutureTask<Void>(DoNothingRunnable.instance());
5156
SCHEDULER.execute(lft);
5257
lft.get();
5358
}
@@ -121,29 +126,29 @@ public void doneMapFailure_executedMapNoOp() {
121126

122127
@Benchmark
123128
public void listener_1CalledOnRun() {
124-
ListenableFutureTask<Void> lft = new ListenableFutureTask<>(false, DoNothingRunnable.instance());
129+
ListenableFutureTask<Void> lft = new ListenableFutureTask<>(DoNothingRunnable.instance());
125130
lft.listener(DoNothingRunnable.instance());
126131
lft.run();
127132
}
128133

129134
@Benchmark
130135
public void listener_1ExecutedOnRun() {
131-
ListenableFutureTask<Void> lft = new ListenableFutureTask<>(false, DoNothingRunnable.instance());
136+
ListenableFutureTask<Void> lft = new ListenableFutureTask<>(DoNothingRunnable.instance());
132137
lft.listener(DoNothingRunnable.instance(), SameThreadSubmitterExecutor.instance());
133138
lft.run();
134139
}
135140

136141
@Benchmark
137142
public void listener_2CalledOnRun() {
138-
ListenableFutureTask<Void> lft = new ListenableFutureTask<>(false, DoNothingRunnable.instance());
143+
ListenableFutureTask<Void> lft = new ListenableFutureTask<>(DoNothingRunnable.instance());
139144
lft.listener(DoNothingRunnable.instance());
140145
lft.listener(DoNothingRunnable.instance());
141146
lft.run();
142147
}
143148

144149
@Benchmark
145150
public void listener_4CalledOnRun() {
146-
ListenableFutureTask<Void> lft = new ListenableFutureTask<>(false, DoNothingRunnable.instance());
151+
ListenableFutureTask<Void> lft = new ListenableFutureTask<>(DoNothingRunnable.instance());
147152
lft.listener(DoNothingRunnable.instance());
148153
lft.listener(DoNothingRunnable.instance());
149154
lft.listener(DoNothingRunnable.instance());
@@ -153,87 +158,87 @@ public void listener_4CalledOnRun() {
153158

154159
@Benchmark
155160
public void resultCallbackOnRun_callWithResult() {
156-
ListenableFutureTask<Void> lft = new ListenableFutureTask<>(false, DoNothingRunnable.instance());
161+
ListenableFutureTask<Void> lft = new ListenableFutureTask<>(DoNothingRunnable.instance());
157162
lft.resultCallback(RESULT_CALLBACK);
158163
lft.run();
159164
}
160165

161166
@Benchmark
162167
public void resultCallbackOnRun_executedWithResult() {
163-
ListenableFutureTask<Void> lft = new ListenableFutureTask<>(false, DoNothingRunnable.instance());
168+
ListenableFutureTask<Void> lft = new ListenableFutureTask<>(DoNothingRunnable.instance());
164169
lft.resultCallback(RESULT_CALLBACK, SameThreadSubmitterExecutor.instance());
165170
lft.run();
166171
}
167172

168173
@Benchmark
169174
public void resultCallbackOnRun_failureNoOp() {
170-
ListenableFutureTask<Void> lft = new ListenableFutureTask<>(false, THROWING_CALLABLE);
175+
ListenableFutureTask<Void> lft = new ListenableFutureTask<>(THROWING_CALLABLE);
171176
lft.resultCallback(RESULT_CALLBACK);
172177
lft.run();
173178
}
174179

175180
@Benchmark
176181
public void resultCallbackOnRun_executedFailureNoOp() {
177-
ListenableFutureTask<Void> lft = new ListenableFutureTask<>(false, THROWING_CALLABLE);
182+
ListenableFutureTask<Void> lft = new ListenableFutureTask<>(THROWING_CALLABLE);
178183
lft.resultCallback(RESULT_CALLBACK, SameThreadSubmitterExecutor.instance());
179184
lft.run();
180185
}
181186

182187
@Benchmark
183188
public void failureCallbackOnRun_callWithFailure() {
184-
ListenableFutureTask<Void> lft = new ListenableFutureTask<>(false, THROWING_CALLABLE);
189+
ListenableFutureTask<Void> lft = new ListenableFutureTask<>(THROWING_CALLABLE);
185190
lft.failureCallback(FAILURE_CALLBACK);
186191
lft.run();
187192
}
188193

189194
@Benchmark
190195
public void failureCallbackOnRun_executedWithFailure() {
191-
ListenableFutureTask<Void> lft = new ListenableFutureTask<>(false, THROWING_CALLABLE);
196+
ListenableFutureTask<Void> lft = new ListenableFutureTask<>(THROWING_CALLABLE);
192197
lft.failureCallback(FAILURE_CALLBACK, SameThreadSubmitterExecutor.instance());
193198
lft.run();
194199
}
195200

196201
@Benchmark
197202
public void failureCallbackOnRun_noOp() {
198-
ListenableFutureTask<Void> lft = new ListenableFutureTask<>(false, DoNothingRunnable.instance());
203+
ListenableFutureTask<Void> lft = new ListenableFutureTask<>(DoNothingRunnable.instance());
199204
lft.failureCallback(FAILURE_CALLBACK);
200205
lft.run();
201206
}
202207

203208
@Benchmark
204209
public void failureCallbackOnRun_executedNoOp() {
205-
ListenableFutureTask<Void> lft = new ListenableFutureTask<>(false, DoNothingRunnable.instance());
210+
ListenableFutureTask<Void> lft = new ListenableFutureTask<>(DoNothingRunnable.instance());
206211
lft.failureCallback(FAILURE_CALLBACK, SameThreadSubmitterExecutor.instance());
207212
lft.run();
208213
}
209214

210215
@Benchmark
211216
public void mapResultOnRun_mapped() {
212-
ListenableFutureTask<Void> lft = new ListenableFutureTask<>(false, DoNothingRunnable.instance());
217+
ListenableFutureTask<Void> lft = new ListenableFutureTask<>(DoNothingRunnable.instance());
213218
@SuppressWarnings("unused")
214219
ListenableFuture<Void> mapped = lft.map(MAPPRER);
215220
lft.run();
216221
}
217222

218223
@Benchmark
219224
public void mapResultOnRun_executedMapped() {
220-
ListenableFutureTask<Void> lft = new ListenableFutureTask<>(false, DoNothingRunnable.instance());
225+
ListenableFutureTask<Void> lft = new ListenableFutureTask<>(DoNothingRunnable.instance());
221226
@SuppressWarnings("unused")
222227
ListenableFuture<Void> mapped = lft.map(MAPPRER, SameThreadSubmitterExecutor.instance());
223228
lft.run();
224229
}
225230

226231
@Benchmark
227232
public void mapResultOnRun_failureMapNoOp() {
228-
ListenableFutureTask<Void> lft = new ListenableFutureTask<>(false, DoNothingRunnable.instance());
233+
ListenableFutureTask<Void> lft = new ListenableFutureTask<>(DoNothingRunnable.instance());
229234
@SuppressWarnings("unused")
230235
ListenableFuture<Void> mapped = lft.mapFailure(Exception.class, FAILURE_MAPPRER);
231236
lft.run();
232237
}
233238

234239
@Benchmark
235240
public void mapResultOnRun_executedFailureMapNoOp() {
236-
ListenableFutureTask<Void> lft = new ListenableFutureTask<>(false, DoNothingRunnable.instance());
241+
ListenableFutureTask<Void> lft = new ListenableFutureTask<>(DoNothingRunnable.instance());
237242
@SuppressWarnings("unused")
238243
ListenableFuture<Void> mapped = lft.mapFailure(Exception.class, FAILURE_MAPPRER,
239244
SameThreadSubmitterExecutor.instance());
@@ -242,31 +247,31 @@ public void mapResultOnRun_executedFailureMapNoOp() {
242247

243248
@Benchmark
244249
public void mapFailureOnRun_mapNoOp() {
245-
ListenableFutureTask<Void> lft = new ListenableFutureTask<>(false, THROWING_CALLABLE);
250+
ListenableFutureTask<Void> lft = new ListenableFutureTask<>(THROWING_CALLABLE);
246251
@SuppressWarnings("unused")
247252
ListenableFuture<Void> mapped = lft.map(MAPPRER);
248253
lft.run();
249254
}
250255

251256
@Benchmark
252257
public void mapFailureOnRun_executedMapNoOp() {
253-
ListenableFutureTask<Void> lft = new ListenableFutureTask<>(false, THROWING_CALLABLE);
258+
ListenableFutureTask<Void> lft = new ListenableFutureTask<>(THROWING_CALLABLE);
254259
@SuppressWarnings("unused")
255260
ListenableFuture<Void> mapped = lft.map(MAPPRER, SameThreadSubmitterExecutor.instance());
256261
lft.run();
257262
}
258263

259264
@Benchmark
260265
public void mapFailureOnRun_mapped() {
261-
ListenableFutureTask<Void> lft = new ListenableFutureTask<>(false, THROWING_CALLABLE);
266+
ListenableFutureTask<Void> lft = new ListenableFutureTask<>(THROWING_CALLABLE);
262267
@SuppressWarnings("unused")
263268
ListenableFuture<Void> mapped = lft.mapFailure(Exception.class, FAILURE_MAPPRER);
264269
lft.run();
265270
}
266271

267272
@Benchmark
268273
public void mapFailureOnRun_executedMapped() {
269-
ListenableFutureTask<Void> lft = new ListenableFutureTask<>(false, THROWING_CALLABLE);
274+
ListenableFutureTask<Void> lft = new ListenableFutureTask<>(THROWING_CALLABLE);
270275
@SuppressWarnings("unused")
271276
ListenableFuture<Void> mapped = lft.mapFailure(Exception.class, FAILURE_MAPPRER,
272277
SameThreadSubmitterExecutor.instance());

0 commit comments

Comments
 (0)