Fork Join

r囧r小猫 2021-09-20 02:58 275阅读 0赞

[2019独角兽企业重金招聘Python工程师标准>>> ][2019_Python_] ![hot3.png][]

package com.eloancn.back.schedule.core.windtalkers;
    
    import java.util.concurrent.ForkJoinPool;
    import java.util.concurrent.Future;
    import java.util.concurrent.RecursiveTask;
    
    /**
     * @author pat
     * @version V1.0
     * @date 2017/12/29 下午3:05
     */
    public class ForkJoiner {
    
        public static void main(String[] args) {
            ForkJoinPool forkJoinPool = new ForkJoinPool();
            MyTask myTask = new MyTask(1, 10);
            Future<Integer> result = forkJoinPool.submit(myTask);
            try {
                Integer sum = result.get();
                System.out.println("sum:" + sum);
            } catch (Exception e) {
                e.printStackTrace();
            }
    
        }
    }
    
    class MyTask extends RecursiveTask<Integer> {
    
        private int start;
        private int end;
    
        public static final int threshold = 2;
    
        MyTask(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;
                MyTask leftTask = new MyTask(start, middle);
                MyTask rightTask = new MyTask(middle + 1, end);
    
                leftTask.fork();
                rightTask.fork();
    
    
                int leftResult = leftTask.join();
                int rightResult = rightTask.join();
    
                sum = leftResult + rightResult;
            }
            return sum;
        }
    }

转载于:https://my.oschina.net/payzheng/blog/1596723

[2019_Python_]: https://my.oschina.net/u/2663968/blog/3061697
[hot3.png]: /images/20210726/99a2b421e9b343679f2679f2341dfed1.png