processor

使用ForkJoin 实现多线程任务调度处理

我们通常会遇见这种情况需要 并行 串行任务按顺序处理

###如图执行顺序如下

• 任务一 任务二 异步执行
• 执行任务三
• 执行任务四
• 任务五，任务六，任务七异步执行

###IProcessor 任务需实现的接口

 /**
     * 任务id
     * @return
     */
    public String id();

    /**
     * 是否是异步
     * @return true 异步，false 同步
     */
    public boolean isAsyn();

    /**
     * 任务逻辑处理
     * @return
     */
    public Object process();

###ProcessorExecuteService 逻辑服务

···

/**
 * 任务执行： 此方法完成之后，所有任务都已经调用完成
 * @return
 */
public void execute(){
    ForkJoinPool pool = new ForkJoinPool();
    pool.invoke(new ProcessorAction(chain));
}

/**
 * 异步执行任务
 */
public Future executeAsync(){
    ForkJoinPool pool = new ForkJoinPool();
    future = pool.submit(new ProcessorAction(chain));
    return future;
}

···

###使用多线程调度测试

        Test t = new Test();
        List<IProcessor> list = new CopyOnWriteArrayList<>();
        list.add(new Process1("任务一",true));
        list.add(new Process1("任务二",true));
        list.add(new Process1("任务三",false));
        list.add(new Process1("任务四",false));
        list.add(new Process1("任务五",true));
        list.add(new Process1("任务六",true));
        list.add(new Process1("任务七",true));


        long start = System.currentTimeMillis();
        ProcessorExecuteService processorPool = new ProcessorExecuteService(list);
        processorPool.executeAsync();

        System.out.println("end execute: " + (System.currentTimeMillis() - start));

        System.out.println(processorPool.getProcessorResult("任务一"));
        System.out.println(processorPool.getProcessorResult("任务二"));
        System.out.println(processorPool.getProcessorResult("任务三"));
        System.out.println(processorPool.getProcessorResult("任务四"));
        System.out.println(processorPool.getProcessorResult("任务五"));
        System.out.println(processorPool.getProcessorResult("任务六"));
        System.out.println(processorPool.getProcessorResult("任务七"));

        System.out.println("end get : " + (System.currentTimeMillis() - start));