Estou a fazer um servidor em java queria executar determinadas tarefas em paralelo. Tenho uma lista de um determinado tipo quero que 20 threads trate de deterimados elementos da lista.
for( Item item : result ) {
Callable< List< IResult > > callable = new HTMLParser( item );
Future< List< IResult > > future = pool.submit( callable );
set.add( future );
}
for( Future< List< IResult > > future : set ) {
List< IResult > result = future.get( ); // wait for a processor to complete
if( result != null && !result.isEmpty( ) )
FResults.addAll( result );
}
}
Só que executando esta soluçao, analisando os logs parece me que está a correr as threads de forma sequencial
2016-12-06 14:17:02.106 DEBUG 18229 --- [pool-1-thread-5] ......
2016-12-06 14:17:02.106 DEBUG 18229 --- [pool-1-thread-5] ....
2016-12-06 14:17:02.106 DEBUG 18229 --- [pool-1-thread-5] .....
2016-12-06 14:17:02.106 DEBUG 18229 --- [pool-1-thread-5] .......
2016-12-06 14:17:02.106 INFO 18229 --- [pool-1-thread-5] .....
2016-12-06 14:17:02.243 DEBUG 18229 --- [ool-1-thread-19] .....
2016-12-06 14:17:02.243 INFO 18229 --- [ool-1-thread-19] ....
2016-12-06 14:17:02.587 DEBUG 18229 --- [ool-1-thread-16] .....
2016-12-06 14:17:02.587 DEBUG 18229 --- [ool-1-thread-16] ....
2016-12-06 14:17:02.587 DEBUG 18229 --- [ool-1-thread-16] .....
2016-12-06 14:17:02.587 DEBUG 18229 --- [ool-1-thread-16] .....
2016-12-06 14:17:02.588 DEBUG 18229 --- [ool-1-thread-16] .....
2016-12-06 14:17:02.588 DEBUG 18229 --- [ool-1-thread-16] ......
2016-12-06 14:17:02.588 DEBUG 18229 --- [ool-1-thread-16] .....
2016-12-06 14:17:02.588 DEBUG 18229 --- [ool-1-thread-16] ....
2016-12-06 14:17:02.588 DEBUG 18229 --- [ool-1-thread-16] ......
2016-12-06 14:17:02.588 DEBUG 18229 --- [ool-1-thread-16] ...
Os logs de uam thread aparece sequencialmente todo seguido, não me faz sentido. Alguma ideia ?
pool
? Poste o código. Além disso é interessante postar mais informações sobre oHTMLParser
, incluindo as linhas que logam o resultado abaixo e qualquer coisa que possa estar sincronizando o código. Só olhando as linhas de código que você postou não dá para dizer muito sobre o problema.