【JUC并发】黑马程序员:ForkJoinPool。fork()/ join() 计算1到100之间的数

发布于:2023-01-31 ⋅ 阅读:(621) ⋅ 点赞:(0)

介绍

  • Fork/Join 是 JDK 1.7 加入的新的线程池实现,它体现的是一种分治思想,适用于能够进行任务拆分的 cpu 密集型 运算

  • 所谓的任务拆分,是将一个大任务拆分为算法上相同的小任务,直至不能拆分可以直接求解。跟递归相关的一些计
    算,如归并排序、斐波那契数列、都可以用分治思想进行求解

  • Fork/Join 在分治的基础上加入了多线程,可以把每个任务的分解和合并交给不同的线程来完成,进一步提升了运 算效率

  • Fork/Join 默认会创建与 cpu 核心数大小相同的线程池

  • 提交给 Fork/Join 线程池的任务需要继承 RecursiveTask(有返回值)或 RecursiveAction(没有返回值)

使用

计算如 1 - 10 的所有数字之和

public class Demo5 {
    public static void main(String[] args) {
        ForkJoinPool forkJoinPool=new ForkJoinPool(4);
        forkJoinPool.invoke(new AddTask(1,10));
    }
    static class AddTask extends RecursiveTask<Integer> {
        int head;
        int last;
        AddTask(int head,int last){
            this.head=head;
            this.last=last;
        }

        @Override
        protected Integer compute() {
            if(head==last){
                return head;
            }
            if (head==last-1){
                System.out.println(head+"-"+last+"相加为"+(head+last));
                return head+last;
            }
            int mid=(head+last)/2;
            AddTask addTask = new AddTask(head, mid);
            addTask.fork();
            AddTask addTask1 = new AddTask(mid + 1, last);
            addTask1.fork();
            int result=addTask.join()+addTask1.join();
            System.out.println(head+"-"+last+"相加为"+result);
            return result;
        }
    }
}

输出

6-7相加为13
1-2相加为3
9-10相加为19
4-5相加为9
1-3相加为6
6-8相加为21
6-10相加为40
1-5相加为15
1-10相加为55

网站公告

今日签到

点亮在社区的每一天
去签到