SpringBootのスレッド実行について

Question

現在、SpringBootでファイルエクスポートのシステムを作っています。
XX件以上であれば、HTTPResponseはすぐに返し、サーバ側では非同期に生成→完了後操作者にメール通知する様にしてます。

実装自体は以下の様に組み、一応動いてる様なのですが、画面からの操作感では本当に非同期に動いてるのか、漠然と疑問に感じます。

と言うのも、検索一覧とExcel出力のロジック自体は共通なのですが、体感レスポンスではエクスポート処理の方がワンクッションレスポンスが遅い様に感じます。

下記の様にServiceクラスをExecutorServiceに乗せて実行していますが、使い方は正しいでしょうか？

Controllerクラス 

    @PostMapping(value = "/export", produces = MediaType.APPLICATION_OCTET_STREAM_VALUE)
    @ResponseStatus(HttpStatus.OK)
    public ResponseEntity<Resource> exportExcel(@RequestBody @Validated MemberSearchParams params) throws IOException, IllegalArgumentException, IllegalAccessException, AuthException {

        List<Member> memberList = memberService.find(params).getList();

　　　　　// １０００件以上はエクスポートファイルをアップロードし、メールで通知する。
        if (memberList.size() > maximumCount) {
            ExecutorService executor = Executors.newSingleThreadExecutor();
            Future<String> future = executor.submit(new Callable<String>() {
                @Override
                public String call() throws IllegalAccessException, IOException {
                    SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyyMMddHHmmss");
                    String fileName = simpleDateFormat.format(new Date());

                    byte[] excelData = memberService.createExcelData(memberList);
                    memberService.awsUpload(toMail, fileName, excelData);
                    return "SUCCESS";
                }
            });
            // 空で返す
            return ResponseEntity.status(HttpStatus.ACCEPTED).headers(new HttpHeaders()).body(new ByteArrayResource( new byte[0]));
        } else {
            byte[] excelData = memberService.createExcelData(memberList);
            HttpHeaders httpHeaders = new HttpHeaders();
            httpHeaders.setContentDispositionFormData("filename", "member.xlsx");
            return ResponseEntity.ok().headers(httpHeaders).body(new ByteArrayResource(excelData));
        }
    }

Serviceクラス

@Service
public class MemberService {
    public byte[] createExcelData(List<HumanResourceSearchItem> list) throws IOException, IllegalArgumentException, IllegalAccessException {
　　　・・
　　}
}

Comments

[m.ts10806]

想定のとおり動いてるのなら「正しい」と言えるのでは。具体的な問題はレスポンスですか？

[bobo]

ありがとうございます。
そうですね。検索一覧では即レスポンスが返って来て、Exportは同じ件数をDLしても数秒かかります。DBからの取得も全く同じなので、差は出ないと思っていたのですが。。

ググるとExecutorも何パターンかあり、こちらの使い方なのかなと疑問を持ちまして。。
(要件的には１スレッドで実行すれば良いのですが、Responseは即返して実行してほしいと思ってます)
final ExecutorService executor = Executors.newSingleThreadExecutor();
final ExecutorService executor = Executors.newFixedThreadPool(2);

[m.ts10806]

非同期とはいえ、投げる分の差はありそうに思います。あくまで私見で手元で試したわけではありませんが

[bobo]

ありがとうございます。
う〜ん、取得件数によって、タイムアウトになってしまいました。
やっぱり同期実行になってる様です。。並列実行になっていない・・のか。。

他のパターンで試してみたいと思います。
final ExecutorService executor = Executors.newFixedThreadPool(1);

[bobo]

やっぱりスレッド生成して投げっぱなししてくれてない様でした。
ググるとParallelStreamのやり方も紹介されていたのでやってみたいと思います。

Answer 1

ログで処理時間を出力した所、処理自体は正しく、並列実行もされている様でした。
ただ、問題はControllerクラスにある様で、どうもThraedが終了するまでResponseを返していない様でした。
本題と変わってしまった為、自己解決とし、別に質問させて頂きます。

ご回答頂きありがとうございました。