java(spring boot)で非同期処理を行う。asyncを使用して容易に実装を行う。

Service クラスの実装

ここでは非同期の具体的な処理を記載する。今回はSleepをかけ、その間でprintlnをすることとする。メソッドにAsyncを付与すること

import java.util.concurrent.CompletableFuture;

import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Service;

@Service
public class AsyncService {

	@Async
	public CompletableFuture<String> async() {
		try {
			System.out.println("exec async start");
			Thread.sleep(9000); // 5秒間の遅延を追加
			System.out.println("exec async end");
		} catch (InterruptedException e) {
			Thread.currentThread().interrupt();
		}
		return CompletableFuture.completedFuture("sync OK");
	}

	@Async
	public CompletableFuture<String> async2() {
		try {
			System.out.println("exec async2 start");
			Thread.sleep(2000); // 2秒間の遅延を追加
			System.out.println("exec async2 end");
		} catch (InterruptedException e) {
			Thread.currentThread().interrupt();
		}
		return CompletableFuture.completedFuture("sync2 OK");
	}

}

Controllerクラスの実装

CompletableFutureを使用し、メソッド呼び出しに非同期処理を記載する。
適当に上記クラスを呼び出す実装を記載（なぜかコード書けない・・・）。
上記Serviceクラスの各メソッドを3回ずつ呼び出す実装だけ行う。

Applicationクラス

EnableAsyncを付与する。Beanで非同期の設定を記載する。

import java.util.concurrent.Executor;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.context.annotation.Bean;
import org.springframework.scheduling.annotation.EnableAsync;
import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;

@EnableAsync
@SpringBootApplication
public class ControllerPracticeApplication {

	public static void main(String[] args) {
		SpringApplication.run(ControllerPracticeApplication.class, args);
	}

	@Bean
    public Executor taskExecutor() {
        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
        executor.setCorePoolSize(5); // スレッドプールのサイズを指定
        executor.setMaxPoolSize(10);
        executor.setQueueCapacity(25);
        return executor;
    }

}

実行結果

下記のようにコンソールに表示された。startが先行して表示されていることから非同期実行ができていると認識。
exec async start
exec async2 start
exec async start
exec async2 start
exec async start
exec async2 end
exec async2 start
exec async2 end
exec async2 end
exec async end
exec async end
exec async end

参考文献

https://spring.pleiades.io/spring-framework/docs/current/javadoc-api/org/springframework/scheduling/annotation/EnableAsync.html