Pelo que li do tutorial, é um pouco diferente.
Em C, quando se faz o fork, você tem 2 processos, um pai e um filho. De posse do pid do filho, o processo pai pode fazer o join, quando o processo filho terminar.
Em Java, o algoritmo é similar, mas o funcionamento para o Sistema Operacional é diferente. O algoritmo é
se (a parte de trabalho for pequena o suficiente)
faça o que tem que fazer
caso contrário
divida o meu trabalho em duas partes
execute as duas partes e espere pelo resultado
Exemplo retirado da Universidade de Washington:
import java.util.concurrent.ForkJoinPool;
import java.util.concurrent.RecursiveTask;
class Sum extends RecursiveTask<Long> {
static final int SEQUENTIAL_THRESHOLD = 5000;
int low;
int high;
int[] array;
Sum(int[] arr, int lo, int hi) {
array = arr;
low = lo;
high = hi;
}
protected Long compute() {
if(high - low <= SEQUENTIAL_THRESHOLD) {
long sum = 0;
for(int i=low; i < high; ++i)
sum += array[i];
return sum;
} else {
int mid = low + (high - low) / 2;
Sum left = new Sum(array, low, mid);
Sum right = new Sum(array, mid, high);
left.fork();
long rightAns = right.compute();
long leftAns = left.join();
return leftAns + rightAns;
}
}
static long sumArray(int[] array) {
return ForkJoinPool.commonPool().invoke(new Sum(array,0,array.length));
}
}
Nesse exemplo, você faz uma soma dos elementos de um Array. Se o array tiver mais que 5000 elementos, a tarefa será dividida. O método compute
implementa o pseudo-código descrito.
Exemplo de ordenação:
static class SortTask extends RecursiveAction {
final long[] array; final int lo, hi;
SortTask(long[] array, int lo, int hi) {
this.array = array; this.lo = lo; this.hi = hi;
}
SortTask(long[] array) { this(array, 0, array.length); }
protected void compute() {
if (hi - lo < THRESHOLD)
sortSequentially(lo, hi);
else {
int mid = (lo + hi) >>> 1;
invokeAll(new SortTask(array, lo, mid),
new SortTask(array, mid, hi));
merge(lo, mid, hi);
}
}
// implementation details follow:
static final int THRESHOLD = 1000;
void sortSequentially(int lo, int hi) {
Arrays.sort(array, lo, hi);
}
void merge(int lo, int mid, int hi) {
long[] buf = Arrays.copyOfRange(array, lo, mid);
for (int i = 0, j = lo, k = mid; i < buf.length; j++)
array[j] = (k == hi || buf[i] < array[k]) ?
buf[i++] : array[k++];
}
}
Primeiro você tem que escolher o tipo de Task
. São duas opções:
RecusiveTask
: devolve um resultado após o fork
ActionTask
: não devolve um resultado após o fork
Segundo tem que implementar o método compute seguindo o pseudo-algoritmo, utilizando invokeAll
, compute
, fork
e join
.
Finalmente, você tem que usar um pool de threads chamado ForkJoinPool
. Vi pelo menos duas formas:
ForkJoinPool.commonPool().invoke(task);
ou
ForkJoinPool pool = new ForkJoinPool();
pool.invoke(task);
Por baixos dos panos, o java.util.Arrays.parallelSort usa Fork/Join API.