0%

线程池

发表于 分类于

文章字数：578,阅读全文大约需要2分钟

降低线程创建和销毁的消耗，提高速度，节约资源，线程可管理。

参数含义

  • int corePoolSize核心线程数
  • int maximumPoolSize最大线程数
  • long keepAliveTime空闲线程存活时间
  • workQueue任务队列
  • threadFactory创建线程的工厂，主要赋予名字
  • RejectedExcutionHandler线程池饱和策略
  1. AbortPolicy抛出异常，默认
  2. CallerRunsPolicy调用者线程执行
  3. DiscardOldestPolicy丢弃最老的任务
  4. DiscardPolicy直接丢弃

实现自己的饱和策略，实现RejectedExcutionHandler就行，保存到数据库之类的。

提交任务

  • execute(Runnable command)不需要返回
  • Future<T> submit(Callable<T> task)有返回

最佳线程数

  • CPU密集型，Runtime.getRuntime().availableProcessors() + 1最大核心数+1
  • IO密集型，尽量大，可以是CPU数 * 2

预定义线程池(全部实现ExecutorService接口)

  • FixedThreadPool
  • SingleThreadExecutor
  • CachedThreadPool
  • WorkStealingPool基于fork/join
  • ScheduledThreadPoolExecutor定时执行的任务，可以指定抛出异常，不影响线程执行。
  • newSingleThreadScheduledExecutor包含一个线程，只需要单个线程执行周期任务，保证任务执行顺序
  1. schedule执行一次，可以延时执行
  2. scheduleAtFixedRate提交固定时间执行任务
  3. scheduleWhithFixedDelay提交固定延时间隔执行的任务
  • scheduleAtFixedRate任务超时，当前一个任务超出下个任务的超时时间，下个任务会在上一个执行后马上执行。

自定义线程池

  • new ThreadPoolExecutor(...)

CompletionService

  • 用于接收线程池返回结果(先结束的先拿)
1
2
3
4
5
6
7
8
// 包装线程池
CompletionService<Integer> cService = new ExcutorCompletionService<>(pool);
// 提交若干任务
cService.submit(new WorkTask(..));
cService.submit(new WorkTask(..));
// 按照执行速度获取执行结果
cService.take().get();
cService.take().get();
  • 内部包装了task会将执行成功的结果放到内部维护的队列中。