FJTask vs Future + Callables + ExecutorService

Question

Цель: сделать что-то вроде простенькой карты / уменьшить. Есть много задач, которые они должны выполняться параллельно, результаты добавляются в коллекцию. Если задание длится дольше определенного времени (например, 3 секунды) - отмените его. Какой способ быстрее и удобнее? Поделитесь своим опытом создания "правильной" многопоточности. спасибо заранее.

FJTask https://docs.google.com/viewer?url=http://gee.cs.oswego.edu/dl/papers/fj.pdf

Answer 1

Посмотрите на ParallelArrayWithMapping . Он используется в ForkJoinPool (аналогично использованию с FJTask). Существует метод под названием Reduce, который может вам помочь. Использование Fork Join Pool и java 7 FJ Framework очень быстрое и предлагает хорошие возможности использования всех доступных процессоров.