@Test
public void testForkJoinSubmit() throws InterruptedException, ExecutionException {

    final ForkJoinPool forkJoinPool = new ForkJoinPool();
    final MyForkJoinTask<String> task = new MyForkJoinTask<String>();
    task.setSuccess(true); // 是否在此任务运行完毕后结束阻塞
    ForkJoinTask<String> result = forkJoinPool.submit(task);
    result.get(); // 如果exec()返回值是false，在此处会阻塞，直到调用complete
}