adaptive-executor-java

自适应的Executor框架封装

• 全局最大线程数设置，防止线程泄露
• 单次任务线程数分配策略定制
• 更友好的批量提交任务API
• 只支持Java8

基本使用

// 声明executor
AdaptiveExecutor executor = AdaptiveExecutor.newBuilder()
        .withGlobalMaxThread(10) // 全局最大线程数10
        .adaptiveThread(5, 8) // 每5个任务使用一个线程，每次提交任务最多使用8个线程
        .maxThreadAsPossible(6) // 每次提交任务最多使用6个线程，尽可能多的使用多线程（这个和上面策略二选一）
        .build();
        
// 调用
Collection<Integer> tasks = Arrays.asList(1, 2, 3); // 原始任务

Map<Integer, String> result = executor.invokeAll(tasks, task -> task + " done."); // 并发执行

executor.run(tasks, System.out::println); // 并发执行，无返回值    

高级使用

可以使用withThreadStrategy(IntUnaryOperator)定制线程派生策略，IntUnaryOperator传入参数为单次提交的任务数，返回需要派生的线程数。不过注意，这个线程数依然受制于全局线程最大数。

例如：

AdaptiveExecutor executor = AdaptiveExecutor.newBuilder()
        .withGlobalMaxThread(10) // 全局最大线程数10
        .withThreadStrategy(keySize -> keySize) // 传入多少key，就建立多少线程，和maxThreadAsPossible(Integer.MAX_VALUE)效果相同
        .build();

注意事项

• 如果派生线程数为1，则会以单线程方式执行，将以调用者线程执行
• 多线程任务，超过线程池允许的线程数后，会阻塞。如果希望超过线程池允许的线程数任务以调用者线程执行，可以使用enableCallerRunsPolicy()开启，这样做能充分利用调用者线程执行任务，不过注意，对于任务执行时间分布比较大的任务，如果出现分配给调用者线程的任务执行时间过长，会阻塞多线程提交，从而造成线程饥饿，请谨慎使用（Java Executor Framework本身CallerRunsPolicy也有一样的问题）
• AdaptiveExecutor是线程安全的，所以建议尽可能的共享实例
• AdaptiveExecutor本身会持有一个线程池，所以在用完之后需要关闭