java web中通过fork join来子任务拆分提高处理速度-白红宇

java web中通过fork join来子任务拆分提高处理速度

阅读量：4220 次

发布时间：2019-05-26

本文共 1659 字，大约阅读时间需要 5 分钟。

场景分析：

在项目中，我们可能一次会请求较多数据（比如：一千条），此时，我们可以用fork/join将一次请求分解成N个子任务（每个任务请求1000/N条数据），假如一次请求一千条耗时5s，则我们分解子任务后耗时大概只需要5/N秒多一点。

这里各处fork join的demo例子，如下所示

举个栗子：

@Slf4jpublic class ForkJoinTaskExample extends RecursiveTask
   
     {    public static final int threshold = 2;    private int start;    private int end;    public ForkJoinTaskExample(int start, int end) {        this.start = start;        this.end = end;    }    @Override    protected Integer compute() {        int sum = 0;        //如果任务足够小就计算任务        boolean canCompute = (end - start) <= threshold;        if (canCompute) {            for (int i = start; i <= end; i++) {                sum += i;            }        } else {            // 如果任务大于阈值，就分裂成两个子任务计算            int middle = (start + end) / 2;            ForkJoinTaskExample leftTask = new ForkJoinTaskExample(start, middle);            ForkJoinTaskExample rightTask = new ForkJoinTaskExample(middle + 1, end);            // 执行子任务            leftTask.fork();            rightTask.fork();            // 等待任务执行结束合并其结果            int leftResult = leftTask.join();            int rightResult = rightTask.join();            // 合并子任务            sum = leftResult + rightResult;        }        return sum;    }    public static void main(String[] args) {        ForkJoinPool forkjoinPool = new ForkJoinPool();        //生成一个计算任务，计算1+2+3+4        ForkJoinTaskExample task = new ForkJoinTaskExample(1, 100);        //执行一个任务        Future
    
      result = forkjoinPool.submit(task);        try {            log.info("result:{}", result.get());        } catch (Exception e) {            log.error("exception", e);        }    }}

上述代码，正确输出5050。

转载地址：http://kwlmi.baihongyu.com/

你可能感兴趣的文章