Example of ForkJoinTask in Java
December 26, 2013
fork() and join() in ForkJoinTask
fork() method is used to execute a task within the ForkJoinPool. It executes task asynchronously. join() methods waits for task completion started by fork() method and returns the result once done. For the demo of fork and join method refer the link .ForkJoinTask .adapt
It returns a new ForkJoinTask that will be invoked using ForkJoinPool. adapt() method can run callable and runnable threads. We will see one demo here.ForkJoinTaskDemo.java
package com.concretepage.util.concurrent;
import java.util.concurrent.Callable;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.ForkJoinPool;
import java.util.concurrent.ForkJoinTask;
public class ForkJoinTaskDemo {
public static void main(String[] args) throws InterruptedException, ExecutionException {
ForkJoinPool fjp = new ForkJoinPool();
DemoTask task = new DemoTask();
ForkJoinTask<String> fjt = ForkJoinTask.adapt(task);
fjp.invoke(fjt);
System.out.println(fjt.isDone());
}
}
class DemoTask implements Callable<String>{
public String call() {
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
System.out.println(e);
}
return "Task Done";
}
}
