大规模Schedule任务实现方案

package com.itlong.bjxizhan.support.web.job.base;  
  
import com.itlong.bjxizhan.common.DbContext;  
import com.itlong.bjxizhan.domain.pojo.Task;  
import com.itlong.bjxizhan.support.web.service.StandardTaskService;  
import org.slf4j.Logger;  
import org.slf4j.LoggerFactory;  
  
import java.util.List;  
  
/** 
 * Created by shenhongxi on 2016/7/12. 
 */  
public class JobRunnable implements Runnable {  
  
    private static final Logger log = LoggerFactory.getLogger(JobRunnable.class);  
  
    private StandardTaskService standardTaskService;  
  
    private List<Task> tasks;  
  
    private String dbKey;  
  
    private String tableIndex;  
  
    @Override  
    public void run() {  
        if (tasks != null) {  
            try {  
                DbContext.setDbKey(dbKey);  
                DbContext.setTableIndex(tableIndex);  
                for (Task task : tasks) {  
                    task.setTableIndex(tableIndex);  
  
                    // 1. 一个job的多个实例，谁先成功锁定任务，谁先处理任务，若处理失败则解锁任务  
                    // 2. 对于1中解锁失败的，要利用另外的job来专门进行解锁  
                    // 3. 将任务分成几批，并行处理  
                    // 4. 这些任务的子任务分批串行处理，同样有锁定-处理-失败解锁  
                    // 5. 对于4中解锁失败的，同样要利用另外的job来专门进行解锁  
                    boolean locked = standardTaskService.lock(task);  
                    if (!locked) continue;  
  
                    boolean result = standardTaskService.process(task);  
  
                    standardTaskService.finished(result, task);  
                }  
            } catch (Exception e) {  
                log.error("Do task error", e);  
                throw new RuntimeException("Do task error");  
            }  
        }  
    }  
  
    public List<Task> getTasks() {  
        return tasks;  
    }  
  
    public void setTasks(List<Task> tasks) {  
        this.tasks = tasks;  
    }  
  
    public StandardTaskService getStandardTaskService() {  
        return standardTaskService;  
    }  
  
    public void setStandardTaskService(StandardTaskService standardTaskService) {  
        this.standardTaskService = standardTaskService;  
    }  
  
    public String getTableIndex() {  
        return tableIndex;  
    }  
  
    public void setTableIndex(String tableIndex) {  
        this.tableIndex = tableIndex;  
    }  
  
    public String getDbKey() {  
        return dbKey;  
    }  
  
    public void setDbKey(String dbKey) {  
        this.dbKey = dbKey;  
    }  
}

原文链接：[http://wely.iteye.com/blog/2319842]