ForkJoin框架使用逻辑

Posted AlgorithmInit

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了ForkJoin框架使用逻辑相关的知识,希望对你有一定的参考价值。

public class ForkJoinLogic extends RecursiveTask<Integer> {
    private int interval;
    private int start;
    private int end;
    private String tableName;
    //实现业务逻辑的成员变量

    public ForkJoinLogic(int interval, int start, int end, String tableName) {
        this.interval = interval;
        this.start = start;
        this.end = end;
        this.tableName = tableName;
    }

    @Override
    protected Integer compute() {
        //flag是指间隔小于某个值
        boolean flag = false;
        if (flag) {
            /**
             * 分页逻辑
             * select * from tableName where ...>0 and ...<...
             *处理的业务逻辑,插入目标数据库
             */
            return 1;
        } else {
            /**
             * 对ResultSet进行fork
             *
             */
            return 1;
        }
    }
}

 

以上是关于ForkJoin框架使用逻辑的主要内容,如果未能解决你的问题,请参考以下文章

JUC高级多线程_09:ForkJoin框架的具体介绍与使用

什么是ForkJoin?看这一篇就能掌握!

Java并发包线程池之ForkJoinPool即ForkJoin框架

ForkJoin框架

ForkJoin的使用及for循环stream并行流三种方式的时间比较

ForkJoin的使用及for循环stream并行流三种方式的时间比较