sparkschedule任务类

import java.util.concurrent.BlockingQueue;
import java.util.concurrent.LinkedBlockingQueue;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;

/**
 * <p>spark 异常处理</p>
 *
 * @author
 * @version V1.0
 * @modify by user: {修改人} 2015年11月2日
 * @modify by reason:{方法名}:{原因}
 */
public class SparkThreadScheduler {

    private static SparkThreadScheduler instance;

    private static int taskTotalNum = 2;

    // 阻塞式任务队列，用于存放提交的任务
    private final BlockingQueue<Runnable> queue = new LinkedBlockingQueue<Runnable>(taskTotalNum);

    // 任务处理线程池
    private final ThreadPoolExecutor threadPool = new ThreadPoolExecutor(taskTotalNum, taskTotalNum, 1,
            TimeUnit.HOURS, queue, new ThreadPoolExecutor.CallerRunsPolicy());

    /**
     * 私有构造函数
     */
    private SparkThreadScheduler() {

    }

    /**
     * 获取单例
     *
     * @return
     * @author
     */
    public static synchronized SparkThreadScheduler getInstance() {
        if (null == instance) {
            instance = new SparkThreadScheduler();
        }
        return instance;
    }

    /**
     * 执行任务提交
     *
     * @param thread
     * @author
     */
    public synchronized void execute(Thread thread) {
        threadPool.submit(thread);
    }

}