ThreadPoolExecutor创建线程池[通俗易懂]

ThreadPoolExecutor创建线程池[通俗易懂]java实现上传下载功能

大家好,又见面了,我是你们的朋友全栈君。如果您正在找激活码,请点击查看最新教程,关注关注公众号 “全栈程序员社区” 获取激活教程,可能之前旧版本教程已经失效.最新Idea2022.1教程亲测有效,一键激活。

Jetbrains全系列IDE稳定放心使用

利用ThreadPoolExecutor来创建线程池

一、引入依赖

<dependency>
            <groupId>com.google.guava</groupId>
            <artifactId>guava</artifactId>
            <version>16.0.1</version>
        </dependency>

二、直接上代码

ThreadFactory namedThreadFactory = new ThreadFactoryBuilder().setNameFormat("test" + "-thread-%d").build();

    ThreadPoolExecutor threadPoolExecutor = new ThreadPoolExecutor(10, 100, 600, TimeUnit.SECONDS,
        new ArrayBlockingQueue<>(65536), namedThreadFactory);
    @RequestMapping("pingTest/{ip}")
    public Result testPingOpenFiles(@PathVariable("ip") String ip) { 
   
        int pingCount= 1000;
        while (pingCount-- > 0) { 
   
            threadPoolExecutor.submit(() -> { 
   
                try { 
   
                    boolean b = MyUtils.ping(ip, 1, 5000);
                    log.info(System.currentTimeMillis() + "--------" + b);
                } catch (Exception e) { 
   
                    e.printStackTrace();
                }
                try { 
   
                    Thread.sleep(1000);
                } catch (Exception e) { 
   
                }
            });
        }
        return new Result(true);
    }

三、参数说明

  1. 参数 corePoolSize

表示线程池的常驻核心线程数。如果设置为 0,则表示在没有任何任务时,销毁线程池;如果大于 0,即使没有任务时也会保证线程池的线程数量等于此值;
应该结合实际业务设置此值的大小。若 corePoolSize 的值较小,则会出现频繁创建和销毁线程情况;若值较大,则会浪费系统资源。
2. 参数 maximumPoolSize

表示线程池最大可以创建的线程数。官方规定此值必须大于 0,也必须大于等于 corePoolSize 的值;
此值只有在任务比较多,且不能存放在任务队列时,才会用到。
3. 参数 keepAliveTime

表示线程的存活时间。当线程池空闲时并且超过了此时间,多余的线程就会销毁,直到线程池中的线程数等于 corePoolSize 的值为止;
若 maximumPoolSize 的值 等于 corePoolSize 的值,则线程池在空闲的时候不会销毁任何线程。
4. 参数 unit

表示存活时间的单位,配合 keepAliveTime 参数共同使用。
5. 参数 workQueue

表示线程池执行的任务队列;
当线程池的所有线程都在处理任务时,若来了新任务则会缓存到此任务队列中,然后等待执行。
6. 参数 threadFactory

表示线程的创建工厂,一般使用默认的线程创建工厂的方法 Executors.defaultThreadFactory()来创建线程。
7. 参数 RejectedExecutionHandler

表示指定线程池的拒绝策略,属于一种限流保护的机制;
当线程池的任务已经在缓存队列 workQueue 中存满了之后,并且不能创建新的线程来执行此任务时,就会用到此拒绝策略
四种拒绝策略
(1) AbortPolicy: 丢弃任务并抛出异常。
(2) DiscardPolicy:丢弃任务但不抛出异常。
(3) DiscardOldestPolicy:丢弃队列最前面的任务,然后重新尝试执行任务
(4) CallerRunsPolicy:由调用线程处理该任务
四、submit()和execute方法区别
1.submit() 方法可以配合 Future来接收线程执行的返回值,而 execute() 不能接收返回值;
2.execute() 方法属于 Executor 接口的方法,而 submit() 方法则是属于 ExecutorService 接口的方法。

版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 举报,一经查实,本站将立刻删除。

发布者:全栈程序员-用户IM,转载请注明出处:https://javaforall.cn/187221.html原文链接:https://javaforall.cn

【正版授权,激活自己账号】: Jetbrains全家桶Ide使用,1年售后保障,每天仅需1毛

【官方授权 正版激活】: 官方授权 正版激活 支持Jetbrains家族下所有IDE 使用个人JB账号...

(0)


相关推荐

  • java多线程(二):synchronize和锁「建议收藏」

    java多线程(二):synchronize和锁「建议收藏」一、多线程情况下的线程安全问题先理解一个概念:线程安全:多个线程访问同一个对象时,如果不用考虑这些线程在运行时环境下的调度和交替执行,也不需要进行额外的同步,或者在调用方进行任何其他操作,调用这个

  • A Game of Thrones(81)

    A Game of Thrones(81)45.EDDARD(0)Painisagiftfromthegods,LordEddard,”GrandMaesterPycelletoldhim.“Itmeanstheboneisknitting,thefleshhealingitself.Bethankful.”  “Iwillbethankfulwhenm…

  • SQL like 模糊查询

    SQL like 模糊查询SQL模糊查询在进行数据库查询时,有完整查询和模糊查询之分。一般模糊查询语句如下:SELECT字段FROM表WHERE某字段Like条件其中关于条件,SQL提供了四种匹配模式:1,% :表示任意0个或多个字符。可匹配任意类型和长度的字符,有些情况下若是中文,请使用两个百分号(%%)表示。

  • 2021前端面试经常被问到的题(附答案)

    2021前端面试经常被问到的题(附答案)一、html二、css1.50道CSS基础面试题(附答案)50道CSS基础面试题(附答案)2.如何居中div?CSS水平居中+垂直居中+水平/垂直居中的方法总结3.CSS3新特性深入了解CSS3新特性4.清除浮动清除浮动的四种方式及其原理理解5.media媒体查询深入浅出篇—media媒体查询-响应式开发必备6.讲一讲Flex布局,以及常用的属性?一…

  • AppCompatActivity.setContentView如何装载视图到AppCompatActivity上

    AppCompatActivity.setContentView如何装载视图到AppCompatActivity上a.Activity中在onCreate中调用setContentView(R.layout.main)是做什么的;b.PhoneWindow;c.DecorView;1.setContentView()调用流程ActivityextendsAppCompatActivity@OverrideprotectedvoidonCreate(BundlesavedInst…

  • ScriptManager局部刷新「建议收藏」

    ScriptManager局部刷新「建议收藏」ScriptManager和UpdatePanel控件联合使用可以实现页面异步局部更新的效果。其中的UpdatePanel就是设置页面中异步局部更新区域,它必须依赖于ScriptManager存在,因为ScriptManger控件提供了客户端脚本生成与管理UpdatePanel的功能。几个重要的属性:ScriptManager控件的EnablePartialRendering属性:true…

发表回复

您的电子邮箱地址不会被公开。

关注全栈程序员社区公众号