Bonjour a tous,
j'utilise ForkJoinPool pour parallélisé un traitement. (Grand nombre d'appel, peux de calcul mais fort temps d'attente pour chaque appel).
Mon problème est que ForkJoinPool limite mon nombre de thread a nbProcesseur - 1.
Voici mon code:
Savez vous comment je peux faire pour faire sauté cette limitation du nombre de thread ?
Code : Sélectionner tout - Visualiser dans une fenêtre à part
1
2
3
4
5
6
7
8
9
10
11
12
13 ForkJoinPool pool = new ForkJoinPool(50); // je voudrais 50 thread simultané for(FileAnalyze fa : filesForAnalyse) fa.fork(); boolean isSucceed = true; for(FileAnalyze fa : filesForAnalyse) isSucceed &= fa.join(); for(FileAnalyze fa : filesForAnalyse) pool.invoke(fa);
(Dans mon cas cela ne surchargera pas mon proc )
Je vous remercie d'avance pour votre aide
PS: resolu
Je suis passer par un Executors.newFixedThreadPool a la place du ForkJoinPool
Partager