parent
79cf554850
commit
f427ac383d
|
|
@ -47,7 +47,7 @@ import org.springframework.util.concurrent.ListenableFutureTask;
|
|||
* @see org.springframework.core.task.TaskExecutor
|
||||
* @see SchedulerFactoryBean#setTaskExecutor
|
||||
*/
|
||||
@SuppressWarnings("removal")
|
||||
@SuppressWarnings({"deprecation", "removal"})
|
||||
public class SimpleThreadPoolTaskExecutor extends SimpleThreadPool
|
||||
implements AsyncListenableTaskExecutor, SchedulingTaskExecutor, InitializingBean, DisposableBean {
|
||||
|
||||
|
|
|
|||
|
|
@ -310,7 +310,7 @@ public class ApplicationListenerMethodAdapter implements GenericApplicationListe
|
|||
return new Object[] {event};
|
||||
}
|
||||
|
||||
@SuppressWarnings({"removal", "unchecked"})
|
||||
@SuppressWarnings({"removal", "unchecked", "deprecation"})
|
||||
protected void handleResult(Object result) {
|
||||
if (reactiveStreamsPresent && new ReactiveResultHandler().subscribeToPublisher(result)) {
|
||||
if (logger.isTraceEnabled()) {
|
||||
|
|
|
|||
|
|
@ -62,7 +62,7 @@ import org.springframework.util.concurrent.ListenableFuture;
|
|||
* @see DefaultManagedTaskExecutor
|
||||
* @see ThreadPoolTaskExecutor
|
||||
*/
|
||||
@SuppressWarnings("removal")
|
||||
@SuppressWarnings({"deprecation", "removal"})
|
||||
public class ConcurrentTaskExecutor implements AsyncListenableTaskExecutor, SchedulingTaskExecutor {
|
||||
|
||||
private static final Executor STUB_EXECUTOR = (task -> {
|
||||
|
|
|
|||
|
|
@ -218,13 +218,13 @@ public class ConcurrentTaskScheduler extends ConcurrentTaskExecutor implements T
|
|||
return super.submit(new DelegatingErrorHandlingCallable<>(task, this.errorHandler));
|
||||
}
|
||||
|
||||
@SuppressWarnings("removal")
|
||||
@SuppressWarnings({"deprecation", "removal"})
|
||||
@Override
|
||||
public org.springframework.util.concurrent.ListenableFuture<?> submitListenable(Runnable task) {
|
||||
return super.submitListenable(TaskUtils.decorateTaskWithErrorHandler(task, this.errorHandler, false));
|
||||
}
|
||||
|
||||
@SuppressWarnings("removal")
|
||||
@SuppressWarnings({"deprecation", "removal"})
|
||||
@Override
|
||||
public <T> org.springframework.util.concurrent.ListenableFuture<T> submitListenable(Callable<T> task) {
|
||||
return super.submitListenable(new DelegatingErrorHandlingCallable<>(task, this.errorHandler));
|
||||
|
|
|
|||
|
|
@ -269,13 +269,13 @@ public class SimpleAsyncTaskScheduler extends SimpleAsyncTaskExecutor implements
|
|||
return super.submit(new DelegatingErrorHandlingCallable<>(task, this.errorHandler));
|
||||
}
|
||||
|
||||
@SuppressWarnings("removal")
|
||||
@SuppressWarnings({"deprecation", "removal"})
|
||||
@Override
|
||||
public org.springframework.util.concurrent.ListenableFuture<?> submitListenable(Runnable task) {
|
||||
return super.submitListenable(TaskUtils.decorateTaskWithErrorHandler(task, this.errorHandler, false));
|
||||
}
|
||||
|
||||
@SuppressWarnings("removal")
|
||||
@SuppressWarnings({"deprecation", "removal"})
|
||||
@Override
|
||||
public <T> org.springframework.util.concurrent.ListenableFuture<T> submitListenable(Callable<T> task) {
|
||||
return super.submitListenable(new DelegatingErrorHandlingCallable<>(task, this.errorHandler));
|
||||
|
|
|
|||
|
|
@ -80,7 +80,7 @@ import org.springframework.util.concurrent.ListenableFutureTask;
|
|||
* @see ThreadPoolExecutorFactoryBean
|
||||
* @see ConcurrentTaskExecutor
|
||||
*/
|
||||
@SuppressWarnings({"serial", "removal"})
|
||||
@SuppressWarnings({"serial", "deprecation", "removal"})
|
||||
public class ThreadPoolTaskExecutor extends ExecutorConfigurationSupport
|
||||
implements AsyncListenableTaskExecutor, SchedulingTaskExecutor {
|
||||
|
||||
|
|
|
|||
|
|
@ -74,7 +74,7 @@ import org.springframework.util.concurrent.ListenableFutureTask;
|
|||
* @see ThreadPoolTaskExecutor
|
||||
* @see SimpleAsyncTaskScheduler
|
||||
*/
|
||||
@SuppressWarnings({"serial", "removal"})
|
||||
@SuppressWarnings({"serial", "deprecation", "removal"})
|
||||
public class ThreadPoolTaskScheduler extends ExecutorConfigurationSupport
|
||||
implements AsyncListenableTaskExecutor, SchedulingTaskExecutor, TaskScheduler {
|
||||
|
||||
|
|
|
|||
|
|
@ -280,7 +280,7 @@ class AnnotationDrivenEventListenerTests {
|
|||
}
|
||||
|
||||
@Test
|
||||
@SuppressWarnings("removal")
|
||||
@SuppressWarnings({"deprecation", "removal"})
|
||||
void listenableFutureReply() {
|
||||
load(TestEventListener.class, ReplyEventListener.class);
|
||||
org.springframework.util.concurrent.SettableListenableFuture<String> future =
|
||||
|
|
|
|||
|
|
@ -275,7 +275,7 @@ class AsyncAnnotationBeanPostProcessorTests {
|
|||
|
||||
Future<Object> failWithFuture();
|
||||
|
||||
@SuppressWarnings("deprecation")
|
||||
@SuppressWarnings({"deprecation", "removal"})
|
||||
org.springframework.util.concurrent.ListenableFuture<Object> failWithListenableFuture();
|
||||
|
||||
void failWithVoid();
|
||||
|
|
@ -310,7 +310,7 @@ class AsyncAnnotationBeanPostProcessorTests {
|
|||
|
||||
@Async
|
||||
@Override
|
||||
@SuppressWarnings("deprecation")
|
||||
@SuppressWarnings({"deprecation", "removal"})
|
||||
public org.springframework.util.concurrent.ListenableFuture<Object> failWithListenableFuture() {
|
||||
throw new UnsupportedOperationException("failWithListenableFuture");
|
||||
}
|
||||
|
|
|
|||
|
|
@ -51,7 +51,7 @@ import static org.assertj.core.api.Assertions.assertThatExceptionOfType;
|
|||
* @author Juergen Hoeller
|
||||
* @author Chris Beams
|
||||
*/
|
||||
@SuppressWarnings({ "resource", "deprecation" })
|
||||
@SuppressWarnings({"resource", "deprecation", "removal"})
|
||||
class AsyncExecutionTests {
|
||||
|
||||
private static String originalThreadName;
|
||||
|
|
|
|||
|
|
@ -32,7 +32,7 @@ import static org.assertj.core.api.Assertions.assertThatExceptionOfType;
|
|||
class AsyncResultTests {
|
||||
|
||||
@Test
|
||||
@SuppressWarnings("removal")
|
||||
@SuppressWarnings({ "deprecation", "removal" })
|
||||
public void asyncResultWithCallbackAndValue() throws Exception {
|
||||
String value = "val";
|
||||
final Set<String> values = new HashSet<>(1);
|
||||
|
|
@ -54,7 +54,7 @@ class AsyncResultTests {
|
|||
}
|
||||
|
||||
@Test
|
||||
@SuppressWarnings("removal")
|
||||
@SuppressWarnings({ "deprecation", "removal" })
|
||||
public void asyncResultWithCallbackAndException() {
|
||||
IOException ex = new IOException();
|
||||
final Set<Throwable> values = new HashSet<>(1);
|
||||
|
|
@ -71,15 +71,15 @@ class AsyncResultTests {
|
|||
});
|
||||
assertThat(values).singleElement().isSameAs(ex);
|
||||
assertThatExceptionOfType(ExecutionException.class)
|
||||
.isThrownBy(future::get)
|
||||
.withCause(ex);
|
||||
.isThrownBy(future::get)
|
||||
.withCause(ex);
|
||||
assertThatExceptionOfType(ExecutionException.class)
|
||||
.isThrownBy(future.completable()::get)
|
||||
.withCause(ex);
|
||||
.isThrownBy(future.completable()::get)
|
||||
.withCause(ex);
|
||||
}
|
||||
|
||||
@Test
|
||||
@SuppressWarnings("removal")
|
||||
@SuppressWarnings({ "deprecation", "removal" })
|
||||
public void asyncResultWithSeparateCallbacksAndValue() throws Exception {
|
||||
String value = "val";
|
||||
final Set<String> values = new HashSet<>(1);
|
||||
|
|
@ -92,7 +92,7 @@ class AsyncResultTests {
|
|||
}
|
||||
|
||||
@Test
|
||||
@SuppressWarnings("removal")
|
||||
@SuppressWarnings({ "deprecation", "removal" })
|
||||
public void asyncResultWithSeparateCallbacksAndException() {
|
||||
IOException ex = new IOException();
|
||||
final Set<Throwable> values = new HashSet<>(1);
|
||||
|
|
@ -100,11 +100,11 @@ class AsyncResultTests {
|
|||
future.addCallback(result -> new AssertionError("Success callback not expected: " + result), values::add);
|
||||
assertThat(values).singleElement().isSameAs(ex);
|
||||
assertThatExceptionOfType(ExecutionException.class)
|
||||
.isThrownBy(future::get)
|
||||
.withCause(ex);
|
||||
.isThrownBy(future::get)
|
||||
.withCause(ex);
|
||||
assertThatExceptionOfType(ExecutionException.class)
|
||||
.isThrownBy(future.completable()::get)
|
||||
.withCause(ex);
|
||||
.isThrownBy(future.completable()::get)
|
||||
.withCause(ex);
|
||||
}
|
||||
|
||||
}
|
||||
|
|
|
|||
|
|
@ -125,7 +125,7 @@ abstract class AbstractSchedulingTaskExecutorTests {
|
|||
}
|
||||
|
||||
@Test
|
||||
@SuppressWarnings("removal")
|
||||
@SuppressWarnings({ "deprecation", "removal" })
|
||||
void submitListenableRunnable() {
|
||||
TestTask task = new TestTask(this.testName, 1);
|
||||
// Act
|
||||
|
|
@ -156,7 +156,7 @@ abstract class AbstractSchedulingTaskExecutorTests {
|
|||
}
|
||||
|
||||
@Test
|
||||
@SuppressWarnings("removal")
|
||||
@SuppressWarnings({ "deprecation", "removal" })
|
||||
void submitFailingListenableRunnable() {
|
||||
TestTask task = new TestTask(this.testName, 0);
|
||||
org.springframework.util.concurrent.ListenableFuture<?> future = executor.submitListenable(task);
|
||||
|
|
@ -185,7 +185,7 @@ abstract class AbstractSchedulingTaskExecutorTests {
|
|||
}
|
||||
|
||||
@Test
|
||||
@SuppressWarnings("removal")
|
||||
@SuppressWarnings({ "deprecation", "removal" })
|
||||
void submitListenableRunnableWithGetAfterShutdown() throws Exception {
|
||||
org.springframework.util.concurrent.ListenableFuture<?> future1 = executor.submitListenable(new TestTask(this.testName, -1));
|
||||
org.springframework.util.concurrent.ListenableFuture<?> future2 = executor.submitListenable(new TestTask(this.testName, -1));
|
||||
|
|
@ -260,7 +260,7 @@ abstract class AbstractSchedulingTaskExecutorTests {
|
|||
}
|
||||
|
||||
@Test
|
||||
@SuppressWarnings("removal")
|
||||
@SuppressWarnings({ "deprecation", "removal" })
|
||||
void submitListenableCallable() {
|
||||
TestCallable task = new TestCallable(this.testName, 1);
|
||||
// Act
|
||||
|
|
@ -275,7 +275,7 @@ abstract class AbstractSchedulingTaskExecutorTests {
|
|||
}
|
||||
|
||||
@Test
|
||||
@SuppressWarnings("removal")
|
||||
@SuppressWarnings({ "deprecation", "removal" })
|
||||
void submitFailingListenableCallable() {
|
||||
TestCallable task = new TestCallable(this.testName, 0);
|
||||
// Act
|
||||
|
|
@ -291,7 +291,7 @@ abstract class AbstractSchedulingTaskExecutorTests {
|
|||
}
|
||||
|
||||
@Test
|
||||
@SuppressWarnings("removal")
|
||||
@SuppressWarnings({ "deprecation", "removal" })
|
||||
void submitListenableCallableWithGetAfterShutdown() throws Exception {
|
||||
org.springframework.util.concurrent.ListenableFuture<?> future1 = executor.submitListenable(new TestCallable(this.testName, -1));
|
||||
org.springframework.util.concurrent.ListenableFuture<?> future2 = executor.submitListenable(new TestCallable(this.testName, -1));
|
||||
|
|
|
|||
|
|
@ -43,7 +43,7 @@ import org.springframework.util.concurrent.ListenableFutureTask;
|
|||
* @see java.util.concurrent.ExecutorService
|
||||
* @see java.util.concurrent.Executors
|
||||
*/
|
||||
@SuppressWarnings("removal")
|
||||
@SuppressWarnings({"deprecation", "removal"})
|
||||
public class TaskExecutorAdapter implements AsyncListenableTaskExecutor {
|
||||
|
||||
private final Executor concurrentExecutor;
|
||||
|
|
|
|||
|
|
@ -33,7 +33,7 @@ import static org.mockito.Mockito.verifyNoInteractions;
|
|||
* @author Arjen Poutsma
|
||||
* @author Sebastien Deleuze
|
||||
*/
|
||||
@SuppressWarnings("removal")
|
||||
@SuppressWarnings({"deprecation", "removal"})
|
||||
class ListenableFutureTaskTests {
|
||||
|
||||
@Test
|
||||
|
|
|
|||
|
|
@ -30,7 +30,7 @@ import static org.assertj.core.api.Assertions.assertThat;
|
|||
*
|
||||
* @author Rossen Stoyanchev
|
||||
*/
|
||||
@SuppressWarnings("removal")
|
||||
@SuppressWarnings({"deprecation", "removal"})
|
||||
class MonoToListenableFutureAdapterTests {
|
||||
|
||||
@Test
|
||||
|
|
|
|||
|
|
@ -36,7 +36,7 @@ import static org.mockito.Mockito.verifyNoMoreInteractions;
|
|||
* @author Mattias Severson
|
||||
* @author Juergen Hoeller
|
||||
*/
|
||||
@SuppressWarnings("removal")
|
||||
@SuppressWarnings({"deprecation", "removal"})
|
||||
class SettableListenableFutureTests {
|
||||
|
||||
private final SettableListenableFuture<String> settableListenableFuture = new SettableListenableFuture<>();
|
||||
|
|
|
|||
|
|
@ -571,7 +571,7 @@ public class SimpAnnotationMethodMessageHandlerTests {
|
|||
|
||||
@Controller
|
||||
@MessageMapping("listenable-future")
|
||||
@SuppressWarnings("removal")
|
||||
@SuppressWarnings({"deprecation", "removal"})
|
||||
private static class ListenableFutureController {
|
||||
|
||||
org.springframework.util.concurrent.ListenableFutureTask<String> future;
|
||||
|
|
|
|||
|
|
@ -194,7 +194,7 @@ class AsyncTests {
|
|||
}
|
||||
|
||||
@GetMapping(params = "listenableFuture")
|
||||
@SuppressWarnings("deprecation")
|
||||
@SuppressWarnings({ "deprecation", "removal" })
|
||||
org.springframework.util.concurrent.ListenableFuture<Person> getListenableFuture() {
|
||||
org.springframework.util.concurrent.ListenableFutureTask<Person> futureTask =
|
||||
new org.springframework.util.concurrent.ListenableFutureTask<>(() -> new Person("Joe"));
|
||||
|
|
|
|||
|
|
@ -334,7 +334,7 @@ class AsyncTests {
|
|||
}
|
||||
|
||||
@RequestMapping(params = "listenableFuture")
|
||||
@SuppressWarnings("deprecation")
|
||||
@SuppressWarnings({"deprecation", "removal"})
|
||||
org.springframework.util.concurrent.ListenableFuture<Person> getListenableFuture() {
|
||||
org.springframework.util.concurrent.ListenableFutureTask<Person> futureTask =
|
||||
new org.springframework.util.concurrent.ListenableFutureTask<>(() -> new Person("Joe"));
|
||||
|
|
|
|||
|
|
@ -37,7 +37,7 @@ import org.springframework.web.method.support.ModelAndViewContainer;
|
|||
*/
|
||||
public class DeferredResultMethodReturnValueHandler implements HandlerMethodReturnValueHandler {
|
||||
|
||||
@SuppressWarnings("removal")
|
||||
@SuppressWarnings({"deprecation", "removal"})
|
||||
@Override
|
||||
public boolean supportsReturnType(MethodParameter returnType) {
|
||||
Class<?> type = returnType.getParameterType();
|
||||
|
|
@ -46,7 +46,7 @@ public class DeferredResultMethodReturnValueHandler implements HandlerMethodRetu
|
|||
CompletionStage.class.isAssignableFrom(type));
|
||||
}
|
||||
|
||||
@SuppressWarnings("removal")
|
||||
@SuppressWarnings({"deprecation", "removal"})
|
||||
@Override
|
||||
public void handleReturnValue(@Nullable Object returnValue, MethodParameter returnType,
|
||||
ModelAndViewContainer mavContainer, NativeWebRequest webRequest) throws Exception {
|
||||
|
|
@ -75,7 +75,7 @@ public class DeferredResultMethodReturnValueHandler implements HandlerMethodRetu
|
|||
WebAsyncUtils.getAsyncManager(webRequest).startDeferredResultProcessing(result, mavContainer);
|
||||
}
|
||||
|
||||
@SuppressWarnings("removal")
|
||||
@SuppressWarnings({"deprecation", "removal"})
|
||||
private DeferredResult<Object> adaptListenableFuture(org.springframework.util.concurrent.ListenableFuture<?> future) {
|
||||
DeferredResult<Object> result = new DeferredResult<>();
|
||||
future.addCallback(new org.springframework.util.concurrent.ListenableFutureCallback<Object>() {
|
||||
|
|
|
|||
|
|
@ -63,7 +63,7 @@ class DeferredResultReturnValueHandlerTests {
|
|||
|
||||
|
||||
@Test
|
||||
@SuppressWarnings("removal")
|
||||
@SuppressWarnings({"deprecation", "removal"})
|
||||
public void supportsReturnType() throws Exception {
|
||||
assertThat(this.handler.supportsReturnType(
|
||||
on(TestController.class).resolveReturnType(DeferredResult.class, String.class))).isTrue();
|
||||
|
|
@ -88,7 +88,7 @@ class DeferredResultReturnValueHandlerTests {
|
|||
}
|
||||
|
||||
@Test
|
||||
@SuppressWarnings("removal")
|
||||
@SuppressWarnings({"deprecation", "removal"})
|
||||
public void listenableFuture() throws Exception {
|
||||
org.springframework.util.concurrent.SettableListenableFuture<String> future =
|
||||
new org.springframework.util.concurrent.SettableListenableFuture<>();
|
||||
|
|
@ -109,7 +109,7 @@ class DeferredResultReturnValueHandlerTests {
|
|||
}
|
||||
|
||||
@Test
|
||||
@SuppressWarnings("removal")
|
||||
@SuppressWarnings({"deprecation", "removal"})
|
||||
public void listenableFutureWithError() throws Exception {
|
||||
org.springframework.util.concurrent.SettableListenableFuture<String> future =
|
||||
new org.springframework.util.concurrent.SettableListenableFuture<>();
|
||||
|
|
@ -150,7 +150,7 @@ class DeferredResultReturnValueHandlerTests {
|
|||
|
||||
DeferredResult<String> handleDeferredResult() { return null; }
|
||||
|
||||
@SuppressWarnings("removal")
|
||||
@SuppressWarnings({"deprecation", "removal"})
|
||||
org.springframework.util.concurrent.ListenableFuture<String> handleListenableFuture() { return null; }
|
||||
|
||||
CompletableFuture<String> handleCompletableFuture() { return null; }
|
||||
|
|
|
|||
|
|
@ -147,7 +147,7 @@ class DefaultTransportRequest implements TransportRequest {
|
|||
|
||||
|
||||
@Deprecated(since = "6.0", forRemoval = true)
|
||||
@SuppressWarnings("removal")
|
||||
@SuppressWarnings({"deprecation", "removal"})
|
||||
public void connect(WebSocketHandler handler,
|
||||
org.springframework.util.concurrent.SettableListenableFuture<WebSocketSession> future) {
|
||||
|
||||
|
|
@ -208,7 +208,7 @@ class DefaultTransportRequest implements TransportRequest {
|
|||
* to connect. Also implements {@code Runnable} to handle a scheduled timeout
|
||||
* callback.
|
||||
*/
|
||||
@SuppressWarnings("removal")
|
||||
@SuppressWarnings({"deprecation", "removal"})
|
||||
private class ListenableConnectCallback implements
|
||||
org.springframework.util.concurrent.ListenableFutureCallback<WebSocketSession>, Runnable {
|
||||
|
||||
|
|
|
|||
|
|
@ -84,7 +84,7 @@ class XhrTransportTests {
|
|||
}
|
||||
|
||||
@Test
|
||||
@SuppressWarnings("deprecation")
|
||||
@SuppressWarnings({"deprecation", "removal"})
|
||||
void connect() {
|
||||
HttpHeaders handshakeHeaders = new HttpHeaders();
|
||||
handshakeHeaders.setOrigin("foo");
|
||||
|
|
|
|||
Loading…
Reference in New Issue