forkjoin源码（fork join）
本文目录一览：
怎么阅读Spring源码
准备工作
1. 安装github：现在spring源代码都在github管理，所以首先需要下载githup，下；
2. 安装gradle构建工具： 下载完后进行解压到任意盘符，然后增加环境变量GRADLE_HOME，并在环境变量bin中增加%GRADLE_HOME%/bin，打开DOS窗口，运行gradle -v，出现版本号等信息，表示安装成功；
3. 下载Spring源码：首先打开git shell，切换到你的工作目录，然后输入以下命令：git clone git://github.com/SpringSource/Spring-framework.git，后面一串是源码下载地址。大概半小时的样子，就可以下载完成，这时候在你的工作目录中就会出现Spring-framework的目录，里面有Spring各组件的源码包；
4. 构建导入：下载下来的代码不能直接导入Eclipse，要先转换成Eclipse能读取的形式。因为所有组件都会依赖spring-core，所有我们首先要转换Spring-core工程，在命令窗口切换到Spring-core工程，运行gradle cleanidea eclipse命令，我们会看到开始下载工程所依赖的jar包，几分钟后执行完毕，再来看Spring-core文件夹，多了.classpath、.project等文件，这是Eclipse工程所必须的，然后可以把他导入到eclipse。因为大部分Spring组件都会用到 spring-beans、spring-context、spring-aop，而他们又依赖spring-expression、spring-instrument，所以我们干脆先把这些工程都进行转换并导入eclipse。
我初次导入过程并不顺利，拿spring-core为例，其中以来的一个jar包是Spring-framework/spring-core/build/libs/spring-asm-repack-4.0.jar，但我工程里面并没有他，只好在网上下载了一个，并加入构建路径，其次我还发现少commons-pool-1.5.3.jar、spring-cglib-repack-3.0.jar，都一一下载，最后还是报错没有java.util.concurrent.ForkJoinPool类，发现这个版本必须使用jdk1.7以上，1.6没有这个包。折腾半天，终于几个工程没变异错误了，向前迈进了一步。
Java 线程问题在线等 急需求代码
import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.ForkJoinTask;
import java.util.concurrent.RecursiveTask;
public class ForkJoin extends RecursiveTaskInteger {
/**
*
*/
private static final long serialVersionUID = -6162301641016381533L;
private Integer minNum;
private Integer maxNum;
private Integer numCountPerTask;
private boolean isStart;
public ForkJoin(Integer minNum, Integer maxNum, Integer numCountPerTask, boolean isStart) {
this.minNum = minNum;
this.maxNum = maxNum;
this.numCountPerTask = numCountPerTask;
this.isStart = isStart;
}
@Override
protected Integer compute() {
ListForkJoinTaskInteger queue = new ArrayList();
Integer taskCount = (maxNum-minNum)/(numCountPerTask - 1);
if(taskCount == 0){
taskCount = (maxNum-minNum)%(numCountPerTask - 1) 0 ? 1 : 0;
if(taskCount == 0){
return 0;
}
}
Integer sum = 0;
if(taskCount == 1){
for(int i = minNum; i = maxNum; i++){
sum += i;
}
}else{
for(int i = 1; i = taskCount; i++){
Integer paramMaxNum = 0;
if(i != taskCount){
paramMaxNum = minNum + numCountPerTask;
}else{
paramMaxNum = maxNum;
}
if(i == 1){
isStart = true;
}else{
isStart = false;
}
ForkJoin fj = new ForkJoin(isStart ? minNum : (minNum + 1), paramMaxNum, numCountPerTask, isStart);
ForkJoinTaskInteger jft = fj.fork();
queue.add(jft);
minNum = minNum + numCountPerTask;
}
}
if(!queue.isEmpty()){
for(ForkJoinTaskInteger fjt: queue){
sum += fjt.join();
}
}
return sum;
}
public static void main(String[] args) {
ForkJoin fj = new ForkJoin(20, 70, 10, true);
Integer res = fj.compute();
System.out.println(res);
}
}
第二题不是很明了 是要干嘛
java fork join fork后什么时候运行
（代码验证） fork确实创建了一个子进程并完全复制父进程，但是子进程是从fork后面那个指令开始执行的。对于原因也很合逻辑，如果子进程也从main开头到尾执行所有指令，那它执行到fork指令时也必定会创建一个子子进程，如此下去这个小小的程序
java fork join和thread的区别
Java并发编程的4种风格：Threads，Executors，ForkJoin和Actors
我们生活在一个事情并行发生的世界。自然地，我们编写的程序也反映了这个特点，它们可以并发的执行。当然除了Python代码（译者注：链接里面讲述了Python的全局解释器锁，解释了原因），不过你仍然可以使用Jython在JVM上运行你的程序，来利用多处理器电脑的强大能力。
然而，并发程序的复杂程度远远超出了人类大脑的处理能力。相比较而言，我们简直弱爆了：我们生来就不是为了思考多线程程序、评估并发访问有限资源以及预测哪里会发生错误或者瓶颈。
面对这些困难，人类已经总结了不少并发计算的解决方案和模型。这些模型强调问题的不同部分，当我们实现并行计算时，可以根据问题做出不同的选择。
在这篇文章中，我将会用对同一个问题，用不同的代码来实现并发的解决方案；然后讨论这些方案有哪些好的地方，有哪些缺陷，可能会有什么样的陷阱在等着你。
我们将介绍下面几种并发处理和异步代码的方式：
• 裸线程
• Executors和Services
• ForkJoin框架和并行流
• Actor模型
为了更加有趣一些，我没有仅仅通过一些代码来说明这些方法，而是使用了一个共同的任务，因此每一节中的代码差不多都是等价的。另外，这些代码仅仅是展示用的，初始化的代码并没有写出来，并且它们也不是产品级的软件示例。
对了，最后一件事：在文章最后，有一个小调查，关于你或者你的组织正在使用哪种并发模式。为了你的工程师同胞们，请填一下调查！
任务
任务：实现一个方法，它接收一条消息和一组字符串作为参数，这些字符串与某个搜索引擎的查询页面对应。对每个字符串，这个方法发出一个http请求来查询消息，并返回第一条可用的结果，越快越好。
如果有错误发生，抛出一个异常或者返回空都是可以的。我只是尝试避免为了等待结果而出现无限循环。
简单说明：这次我不会真正深入到多线程如何通讯的细节，或者深入到Java内存模型。如果你迫切地想了解这些，你可以看我前面的文章利用JCStress测试并发。
那么，让我们从最直接、最核心的方式来在JVM上实现并发：手动管理裸线程。
方法1：使用“原汁原味”的裸线程
解放你的代码，回归自然，使用裸线程！线程是并发最基本的单元。Java线程本质上被映射到操作系统线程，并且每个线程对象对应着一个计算机底层线程。
自然地，JVM管理着线程的生存期，而且只要你不需要线程间通讯，你也不需要关注线程调度。
每个线程有自己的栈空间，它占用了JVM进程空间的指定一部分。
线程的接口相当简明，你只需要提供一个Runnable，调用.start()开始计算。没有现成的API来结束线程，你需要自己来实现，通过类似boolean类型的标记来通讯。
