Exécution asynchrone ne fonctionne pas avec Spring Async

Pour information voici une vue du code utilisé :

Le point d'entrée :

Code:

1
2
3
4
5
6
7
@SpringBootApplication
public class Application {
 
	public static void main(String[] args) {
		SpringApplication.run(Application.class, args);
	}
}

La configuration de mon thread (optionnelle) :

Code:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
@Configuration
@EnableAsync
public class ThreadConfig {
 
    @Bean("specificTaskExecutor")
    public TaskExecutor threadPoolTaskExecutor() {
        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
        executor.setCorePoolSize(1);
        executor.setMaxPoolSize(4);
        executor.setThreadNamePrefix("testThread");
        executor.initialize();
        return executor;
    }
}

La méthode asynchrone exécutée :

Code:

1
2
3
4
5
6
7
8
9
10
11
12
@Component
public class PrintThreadId {
 
    @Async("specificTaskExecutor")
    public static Long runFromAnotherThreadPool() throws InterruptedException {
        Long threadId = Thread.currentThread().getId();
        TimeUnit.SECONDS.sleep(1);
        System.out.println("Thread Id :" + threadId);
        return threadId;
    }
 
}

Le test qui est ko :

Code:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
@RunWith(SpringRunner.class)
@SpringBootTest
public class ApplicationTests {
 
	@MockBean
	PrintThreadId printThreadId;
 
	@Test
	public void shouldTestAsynchronousExecution() throws InterruptedException {
 
		final Integer NB_EXPECTED_THREAD = 10;
		ArrayList<Long> threadIds = new ArrayList<>();
 
		for (int i=0; i<NB_EXPECTED_THREAD; i++) {
			Long threadId = printThreadId.runFromAnotherThreadPool();
			if (!threadIds.contains(threadId)) {
				threadIds.add(threadId);
			}
		}
		assertTrue(threadIds.size()==NB_EXPECTED_THREAD);
	}
}