Discussion :

[bernidupont]

Bonsoir,

J'ai créé un projet de test pour tester l'exécution d'une méthode asynchrone avec Spring mais cela ne fonctionne pas comme prévu.
La méthode testée s'exécute toujours dans le même thread. dont l'ID est 1.
Le test qui devrait passé se nomme : shouldTestAsynchronousExecution().

J'ai mis en ligne ce projet de test sous Github dont voici le lien : https://github.com/bernidupont/asyncProject

Avez-vous une idée de la cause de ce mauvais comportement ?

Merci d'avance pour votre aide.

Berni.

[bernidupont]

Pour information voici une vue du code utilisé :

Le point d'entrée :

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

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 :

Sélectionner tout - Visualiser dans une fenêtre à part

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 :

Sélectionner tout - Visualiser dans une fenêtre à part

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 :

Sélectionner tout - Visualiser dans une fenêtre à part

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);
	}
}