Skip to content

Commit 61f7087

Browse files
committed
Consistently apply TaskDecorator to ManagedExecutorService as well
Closes gh-32455
1 parent 2ff8a00 commit 61f7087

File tree

1 file changed

+5
-11
lines changed

1 file changed

+5
-11
lines changed

spring-context/src/main/java/org/springframework/scheduling/concurrent/ConcurrentTaskExecutor.java

+5-11
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,5 @@
11
/*
2-
* Copyright 2002-2023 the original author or authors.
2+
* Copyright 2002-2024 the original author or authors.
33
*
44
* Licensed under the Apache License, Version 2.0 (the "License");
55
* you may not use this file except in compliance with the License.
@@ -133,11 +133,6 @@ public final Executor getConcurrentExecutor() {
133133
* execution callback (which may be a wrapper around the user-supplied task).
134134
* <p>The primary use case is to set some execution context around the task's
135135
* invocation, or to provide some monitoring/statistics for task execution.
136-
* <p><b>NOTE:</b> Exception handling in {@code TaskDecorator} implementations
137-
* is limited to plain {@code Runnable} execution via {@code execute} calls.
138-
* In case of {@code #submit} calls, the exposed {@code Runnable} will be a
139-
* {@code FutureTask} which does not propagate any exceptions; you might
140-
* have to cast it and call {@code Future#get} to evaluate exceptions.
141136
* @since 4.3
142137
*/
143138
public final void setTaskDecorator(TaskDecorator taskDecorator) {
@@ -178,11 +173,10 @@ public <T> ListenableFuture<T> submitListenable(Callable<T> task) {
178173
}
179174

180175

181-
private TaskExecutorAdapter getAdaptedExecutor(Executor concurrentExecutor) {
182-
if (managedExecutorServiceClass != null && managedExecutorServiceClass.isInstance(concurrentExecutor)) {
183-
return new ManagedTaskExecutorAdapter(concurrentExecutor);
184-
}
185-
TaskExecutorAdapter adapter = new TaskExecutorAdapter(concurrentExecutor);
176+
private TaskExecutorAdapter getAdaptedExecutor(Executor originalExecutor) {
177+
TaskExecutorAdapter adapter =
178+
(managedExecutorServiceClass != null && managedExecutorServiceClass.isInstance(originalExecutor) ?
179+
new ManagedTaskExecutorAdapter(originalExecutor) : new TaskExecutorAdapter(originalExecutor));
186180
if (this.taskDecorator != null) {
187181
adapter.setTaskDecorator(this.taskDecorator);
188182
}

0 commit comments

Comments
 (0)