zoukankan      html  css  js  c++  java
  • 线程池

    开门一张图

    各个参数含义

    int corePoolSize  :线程池中核心线程数。       < corePoolSize  ,就会创建新线程 。       > corePoolSize 这个任务就会保存到BlockingQueue。  注意:线程池最开始是没有线程的,当有任务的时候才new线程,然后保持corePoolSize核心线程的大小数量。超过的话就根据keepAliveTime时间来关闭多余的线程。   如果调用prestartAllCoreThreads()方法就会一次性的启动corePoolSize  个数的线程

    int maximumPoolSize, 允许的最大线程数,BlockingQueue也满了,< maximumPoolSize时候就会再次创建新的线程

    long keepAliveTime, 线程空闲下来后,存活的时间,这个参数只在> corePoolSize才有用    TimeUnit unit, 存活时间的单位值

    BlockingQueue<Runnable> workQueue, 保存任务的阻塞队列

    ThreadFactory threadFactory, 创建线程的工厂,给新建的线程赋予名字

    RejectedExecutionHandler handler :饱和策略

    • AbortPolicy :直接抛出异常,默认;
    • CallerRunsPolicy:用调用者所在的线程来执行任务
    • DiscardOldestPolicy:丢弃阻塞队列里最老的任务,队列里最靠前的任务
    • DiscardPolicy :当前任务直接丢弃
    • 实现自己的饱和策略,实现RejectedExecutionHandler接口即可

    提交任务

    execute(Runnable command)  不需要返回

    Future<T> submit(Callable<T> task) 需要返回

    关闭线程池

    shutdown(),shutdownNow();

    shutdownNow():设置线程池的状态,还会尝试停止正在运行或者暂停任务的线程

    shutdown()设置线程池的状态,只会中断所有没有执行任务的线程

    合理配置线程池

    机器的Cpu核心=Runtime.getRuntime().availableProcessors();   线程数适当大一点,机器的Cpu核心数*2,

    队列的选择上,应该使用有界,无界队列可能会导致内存溢出,OOM

    预定义的线程池

    FixedThreadPool

    创建固定线程数量的,适用于负载较重的服务器,使用了无界队列

    SingleThreadExecutor

    创建单个线程,需要顺序保证执行任务,不会有多个线程活动,使用了无界队列

    CachedThreadPool

    会根据需要来创建新线程的,执行很多短期异步任务的程序,使用了SynchronousQueue

    WorkStealingPool(JDK7以后)

    基于ForkJoinPool实现

    ScheduledThreadPoolExecutor

    需要定期执行周期任务,Timer不建议使用了。

    newSingleThreadScheduledExecutor:只包含一个线程,只需要单个线程执行周期任务,保证顺序的执行各个任务

    newScheduledThreadPool 可以包含多个线程的,线程执行周期任务,适度控制后台线程数量的时候

    方法说明:

    schedule:只执行一次,任务还可以延时执行

    scheduleAtFixedRate:提交固定时间间隔的任务    比如说规定60秒执行一次。0秒的时候,第一个任务执行了10秒,那第二个任务会在第60秒的时候执行。会出现超时的情况,

      

    scheduleAtFixedRate任务超时:

    规定60s执行一次,有任务执行了80S,下个任务马上开始执行

    第一个任务 时长 80s,第二个任务20s,第三个任务 50s

    第一个任务第0秒开始,第80S结束;

    第二个任务第80s开始,在第100秒结束;

    第三个任务第120s秒开始,170秒结束

    第四个任务从180s开始

    scheduleWithFixedDelay:提交固定延时间隔执行的任务   比如说  规定60秒执行一次。0秒的时候,第一个任务执行了10秒,那第二个任务会在第70秒的时候执行  ,永远不会出现超时的情况。

    建议在提交给ScheduledThreadPoolExecutor的任务要住catch异常。

  • 相关阅读:
    通过SQLServer的数据库邮件来发送邮件
    sql生成数据库的序列号
    存储过程备份数据库
    LED客显的类
    坦克大战java版
    连连看java版
    贪吃蛇java版
    分享插件 javascript
    js实现上传图片及时预览
    json返回date类型转为字符串
  • 原文地址:https://www.cnblogs.com/coder-lzh/p/10753815.html
Copyright © 2011-2022 走看看