Как обнаружить конец метода @Async в Spring Boot и затем запустить некоторый код; ⇐ JAVA

[Anonymous]

Я пишу приложение Spring Boot, в котором хочу выполнить несколько многопоточных вычислений в фоновом режиме. Одновременно в очереди может находиться от нескольких до нескольких тысяч вычислений, поэтому я не хочу полагаться исключительно на QueueCapacity ThreadPoolTaskExecutor. Как лучше всего решить эту проблему?
Я думал о том, чтобы в конце рекурсивно вызвать метод Calculate, но, насколько я знаю, это не божественная идея (поправьте меня, если Я ошибаюсь).
Вот как сейчас выглядит мое приложение:
AsyncConfig.java
@Configuration
@EnableAsync
public class AsyncConfig {

@Bean(name = "taskExecutor")
public ThreadPoolTaskExecutor taskExecutor() {
ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
executor.setQueueCapacity(100);
executor.setCorePoolSize(2);
executor.setMaxPoolSize(10);
executor.setThreadNamePrefix("taskExecutor-");
executor.initialize();
return executor;
}
}

CalculationContext.java
import lombok.extern.java.Log;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.scheduling.annotation.Async;
import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
import org.springframework.stereotype.Component;

import java.util.concurrent.BlockingQueue;
import java.util.concurrent.CompletionService;
import java.util.concurrent.ExecutorCompletionService;
import java.util.concurrent.LinkedBlockingQueue;

@Log
@Component
public class CalculationContext {

private final SettingsContext settingsContext;
private final ThreadPoolTaskExecutor taskExecutor;
private final CompletionService completionService;

private final BlockingQueue queue = new LinkedBlockingQueue();

public CalculationContext(
SettingsContext settingsContext,
@Qualifier("taskExecutor") ThreadPoolTaskExecutor taskExecutor
) {
this.settingsContext = settingsContext;
this.taskExecutor = taskExecutor;
this.completionService = new ExecutorCompletionService(taskExecutor);
}

public void addToQueue(CalculationData data) {
queue.add(data);
startScraping();
}

public void startCalculation() {
if (queue.isEmpty()) return;
if (getAvailableThreads() == 0) return;

do {
try {
CalculationData data = queue.take();
scrapePage(data);
} catch (InterruptedException e) {
throw new RuntimeException(e);
}
} while (getAvailableThreads() > 0);

}

@Async
public void calculate(CalculationData data) {
//This is where all logic will be
}

private int getAvailableThreads() {
return taskExecutor.getMaxPoolSize() - taskExecutor.getActiveCount();
}
}


Подробнее здесь: https://stackoverflow.com/questions/790 ... -code-then