Code samples for spring @Async annotation.

spring-all/src/main/java/org/baeldung/async/AsyncAnnotationExample.java

@@ -0,0 +1,43 @@
+package org.baeldung.async;
+
+import java.util.concurrent.Future;
+
+import org.springframework.scheduling.annotation.Async;
+import org.springframework.scheduling.annotation.AsyncResult;
+import org.springframework.stereotype.Component;
+
+@Component
+public class AsyncAnnotationExample {
+
+	@Async
+	public void asyncMethodWithVoidReturnType() {
+		System.out.println("Execute method asynchronously. "
+				+ Thread.currentThread().getName());
+	}
+
+	@Async
+	public Future<String> asyncMethodWithReturnType() {
+		System.out.println("Execute method asynchronously "
+				+ Thread.currentThread().getName());
+		try {
+			Thread.sleep(5000);
+			return new AsyncResult<String>("hello world !!!!");
+		} catch (final InterruptedException e) {
+
+		}
+
+		return null;
+	}
+
+	@Async("threadPoolTaskExecutor")
+	public void asyncMethodWithConfiguredExecutor() {
+		System.out
+				.println("Execute method asynchronously with configured executor"
+				+ Thread.currentThread().getName());
+	}
+
+	@Async
+	public void asyncMethodWithExceptions() throws Exception {
+		throw new Exception("Throw message from asynchronous method. ");
+	}
+}

spring-all/src/main/java/org/baeldung/async/CustomAsyncExceptionHandler.java

@@ -0,0 +1,21 @@
+package org.baeldung.async;
+
+import java.lang.reflect.Method;
+
+import org.springframework.aop.interceptor.AsyncUncaughtExceptionHandler;
+
+public class CustomAsyncExceptionHandler implements
+AsyncUncaughtExceptionHandler {
+
+	@Override
+	public void handleUncaughtException(final Throwable throwable,
+			final Method method, final Object... obj) {
+		System.out.println("Exception message - " + throwable.getMessage());
+		System.out.println("Method name - " + method.getName());
+		for (final Object param : obj) {
+			System.out.println("Param - " + param);
+		}
+
+	}
+
+}

spring-all/src/main/java/org/baeldung/async/config/SpringAsyncConfig.java

@@ -0,0 +1,34 @@
+package org.baeldung.async.config;
+
+import java.util.concurrent.Executor;
+
+import org.baeldung.async.CustomAsyncExceptionHandler;
+import org.springframework.aop.interceptor.AsyncUncaughtExceptionHandler;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.ComponentScan;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.core.task.SimpleAsyncTaskExecutor;
+import org.springframework.scheduling.annotation.AsyncConfigurer;
+import org.springframework.scheduling.annotation.EnableAsync;
+import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
+
+@Configuration
+@EnableAsync()
+@ComponentScan("org.baeldung.async")
+public class SpringAsyncConfig implements AsyncConfigurer {
+
+	@Bean(name = "threadPoolTaskExecutor")
+	public Executor threadPoolTaskExecutor() {
+		return new ThreadPoolTaskExecutor();
+	}
+
+	@Override
+	public Executor getAsyncExecutor() {
+		return new SimpleAsyncTaskExecutor();
+	}
+
+	@Override
+	public AsyncUncaughtExceptionHandler getAsyncUncaughtExceptionHandler() {
+		return new CustomAsyncExceptionHandler();
+	}
+}