线程池我的使用 - 程序员大晖 Blog

线程池

/**

@author ZuoHui
@date 2019/9/29 0029 - 23:12 */ public class ConcurrentPoolImpl implements ConcurrentPoolInter {

private ThreadPoolExecutor threadPoolExecutor; // 核心线程数 private int corePoolSize = 8; // 最大线程数 private int maximumPoolSize = 15; // 超时时间30秒 private long keepAliveTime = 30;

@Override public void initConcurrentThreadPool() { threadPoolExecutor = new ThreadPoolExecutor(corePoolSize,maximumPoolSize, keepAliveTime, TimeUnit.SECONDS,new LinkedBlockingDeque()); }

@Override public V submit(CallableTemplate task) throws InterruptedException, ExecutionException { Future result = threadPoolExecutor.submit(task); return result.get(); }

@Override public List invokeAll(List<? extends CallableTemplate> tasks) throws InterruptedException, ExecutionException {
```
 List<Future<V>> tasksResult = threadPoolExecutor.invokeAll(tasks);
 List<V> resultList = new ArrayList<V>();

 for (Future<V> future : tasksResult) {
     resultList.add(future.get());
 }

 return resultList;
```
} }

/**
@author ZuoHui
@date 2019/9/29 0029 - 23:09 / public abstract class CallableTemplate implements Callable { /*
- 前置处理，子类可以Override该方法 / public void beforeProcess() { System.out.println("before process...."); } /*
- 处理业务逻辑的方法,需要子类去Override
- @return / public abstract V process() throws UnsupportedEncodingException, NoSuchAlgorithmException; /*
- 后置处理，子类可以Override该方法 */ public void afterProcess() { System.out.println("after process...."); } @Override public V call() throws Exception { beforeProcess(); V result = process(); afterProcess(); return result; } }
/**
@author ZuoHui
@date 2019/9/29 0029 - 23:11 / interface ConcurrentPoolInter { /*
- 初始化线程池 */ void initConcurrentThreadPool();
/**
- 提交单个任务
- @param task
- @return */ V submit(CallableTemplate task) throws InterruptedException, ExecutionException;
/**
- 提交多个任务
- @param tasks
- @return */ List invokeAll(List<? extends CallableTemplate> tasks) throws InterruptedException, ExecutionException; }

本站文章除注明转载/出处外，均为本站原创或翻译，转载前请务必署名,转载请标明出处
最后编辑时间为: 2019/11/25 22:26