Nombre maximal de thread avec ForkJoinPool
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:
Code:
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); |
Savez vous comment je peux faire pour faire sauté cette limitation du nombre de thread ?
(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
