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; } } }
时间: 2024-10-18 21:35:01