美文网首页
线程池的基本使用

线程池的基本使用

作者: 笑疯子 | 来源:发表于2020-10-20 18:17 被阅读0次

线程池作用

借由《Java并发编程的艺术》

  • 降低资源消耗。通过重复利用已经创建的线程,能够降低线程创建和销毁造成的消耗。
  • 提高响应速度。当任务到达时,任务可以不需要等待线程的创建就能立即执行。
  • 提高线程的可管理性。线程是稀缺资源,如果无限制地创建,不仅会消耗系统资源,还会降低系统的稳定性,使用线程池可以进行统一的分配,调优和监控。

ThreadPoolExecutor类

public ThreadPoolExecutor(int corePoolSize,
                          int maximumPoolSize,
                          long keepAliveTime,
                          TimeUnit unit,
                          BlockingQueue<Runnable> workQueue,
                          ThreadFactory threadFactory,
                          RejectedExecutionHandler handler) {
    ...
}

ThreadPoolExecutor构造

ThreadPoolExecutor类的构造参数:

  • corePoolSize:核心线程数量,初始化就创建的线程,没有任务也不会被关闭的线程。也会有例外,如:allowCoreThreadTimeOut设置为true时,会被关闭。
  • maximumPoolSize:最大线程数量。
  • keepAliveTime:空闲线程的存活时间,超时后线程会被关闭,核心线程除外。
  • unit:空闲时间单位,一般使用TimeUnit枚举
  • workQueue:工作队列,当所有线程都被占用后,新的任务就会被放在工作队列中。
  • threadFactory:线程工厂。
  • handler:饱和策略,用于线程池中没有空闲线程可以使用且工作列也处于饱和状态时执行的拒绝策略。

常用的拒绝策略

  • AbortPolicy:抛出RejectedExecutionException异常拒绝新的任务处理,默认拒绝策略。
  • CallerRunsPolicy:如果程序关闭,会丢掉任务。此策略提供简单的反馈控制机制,能够减缓新任务的提交速度,但会造成延迟。如果项目可以承受延迟且不能丢弃任何一个任务请求,可以使用此策略。
  • DiscardPolicy:不处理新任务,直接丢掉。
  • DiscardOldestPolicy:丢失最早的未处理的任务。

ThreadPoolExecutor线程状态

  • RUNNING:接收新的任务和处理队列中的任务
  • SHUTDOWN:不能新增任务,但是会继续处理已经添加的任务
  • STOP:不能新增任务,不会继续处理已经添加任务
  • TIDYING:所有的任务已经被终止,工作线程为0
  • TERMINATED:terminated()方法执行完成

创建线程池

创建Runnable接口实现类

public class MyThread implements Runnable {

    private String taskName;

    public MyThread(String taskName) {
        this.taskName = taskName;
    }

    @Override
    public void run() {
        try {
            String threadName = Thread.currentThread().getName();
            System.out.println("线程 " + threadName + " 开始执行:" + taskName);
            Thread.sleep(3000);
            System.out.println("线程 " + threadName + " 开始执行:" + taskName);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }

    @Override
    public String toString() {
        return "MyThread{" +
                "taskName='" + taskName + '\'' +
                '}';
    }
}

使用ThreadPoolExecutor创建

public static void main(String[] args) {

    ThreadPoolExecutor executor = new ThreadPoolExecutor(
            // 核心线程数
            5,
            // 最大线程数
            10,
            // 等待时间
            100,
            // 等待时间单位  秒
            TimeUnit.SECONDS,
            // 任务队列 容量100
            new ArrayBlockingQueue<>(100),
            // 饱和策略
            new ThreadPoolExecutor.CallerRunsPolicy()
    );

    for (int i = 1; i <= 10; i++) {
        MyThread myThread = new MyThread("任务" + i);
        executor.execute(myThread);
    }

    executor.shutdown();
}

几种常见的线程池

固定线程池(FixThreadPool)

线程池中的固定数量线程可以重复使用

public static ExecutorService newFixedThreadPool(int nThreads, ThreadFactory threadFactory) {
    return new ThreadPoolExecutor(nThreads, nThreads,
                                  0L, TimeUnit.MILLISECONDS,
                                  new LinkedBlockingQueue<Runnable>(),
                                  threadFactory);
}

创建方法:

ExecutorService executor = Executors.newFixedThreadPool(5);
for (int i = 1; i <= 10; i++) {
    MyThread myThread = new MyThread("任务" + i);
    executor.execute(myThread);
}
  • 当前运行的线程数小于coreSize的时候,有新任务就创建线程来执行。
  • 当前运行的线程数等于coreSize的时候,有新任务将会追加到LinkedBlockingQueue队列中。
  • 线程池中的线程执行完后,会循环从LinkedBlockingQueue中获取任务执行。

需要注意的是,LinkedBlockingQueue是一个无界队列,它的容量为:Integer.MAX_VALUE,也就是说,当所有线程被占用后,新的任务将会无限堆加到这个队列中,如果任务较多,可能会出现OOM现象。

单一线程池(SingleThreadExecutor)

只有一个线程,空闲也不会被关闭。

public static ExecutorService newSingleThreadExecutor() {
    return new FinalizableDelegatedExecutorService
        (new ThreadPoolExecutor(1, 1,
                                0L, TimeUnit.MILLISECONDS,
                                new LinkedBlockingQueue<Runnable>()));
}

创建方法:

ExecutorService executor = Executors.newSingleThreadExecutor();
for (int i = 1; i <= 10; i++) {
    MyThread myThread = new MyThread("任务" + i);
    executor.execute(myThread);
}

缓存线程池(CachedThreadPool)

线程数量为Integer.MAX_VALUE,空闲线程会被临时缓存60s,没有任务分配会关闭。如果提交任务速度过快,也一样可能会出现OOM现象。

public static ExecutorService newCachedThreadPool() {
    return new ThreadPoolExecutor(0, Integer.MAX_VALUE,
                                  60L, TimeUnit.SECONDS,
                                  new SynchronousQueue<Runnable>());
}

创建方法:

ExecutorService executor = Executors.newCachedThreadPool();
for (int i = 1; i <= 10; i++) {
    MyThread myThread = new MyThread("任务" + i);
    executor.execute(myThread);
}

原文发布在:传送门

相关文章

  • 1203-AsyncTask详解一:线程池的基本设置

    AsyncTask的内部使用线程池处理并发,要了解它是怎样使用线程池的,那要先了解线程池的基本设置 线程池的基本参...

  • 线程池

    1.为什么要使用线程池?2.线程池的基本原理是什么?3.怎么学习线程池?线程池使用了池化技术。池化技术用于我们常见...

  • HystrixCommand实现线程隔离

    Hystrix的基本使用 线程隔离原理 存在全局的线程池线程池缓存,根据threadPoolKey来区分不同的线程...

  • python3 线程池和异常处理

    引用 线程池的基本使用as_completedwaitmap 线程池的异常处理 进程池用法 引用 Python中已...

  • Java线程池如何保证线程池的核心线程存活不被销毁?execut

    线程池介绍 基本元素 线程池是一个创建使用线程并能保存使用过的线程以达到服用的对象,他使用workQueue当作阻...

  • 线程池基本使用

    1. 线程池使用 使用new Thread()创建线程存在的问题: 频繁创建线程,执行完后又被回收,导致频繁GC ...

  • 线程池解析第一章-源码解析

    线程池解析第一章-源码解析线程池解析第二章-线程池源码问题总结 线程池基本介绍 为什么要使用线程池 对于系统和服务...

  • 线程池的基本使用

    说起线程池,我们先来简单说一下线程池的好处:a. 重用存在的线程,减少对象创建、消亡的开销,性能佳。b. 可有效控...

  • 线程池的基本使用

    线程池作用 借由《Java并发编程的艺术》 降低资源消耗。通过重复利用已经创建的线程,能够降低线程创建和销毁造成的...

  • Java线程池的使用

    线程类型: 固定线程 cached线程 定时线程 固定线程池使用 cache线程池使用 定时调度线程池使用

网友评论

      本文标题:线程池的基本使用

      本文链接:https://www.haomeiwen.com/subject/hyodmktx.html