栏目分类:
子分类:
返回
名师互学网用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
名师互学网 > IT > 软件开发 > 后端开发 > Java

Executors 6种线程池创建

Java 更新时间: 发布时间: IT归档 最新发布 模块sitemap 名妆网 法律咨询 聚返吧 英语巴士网 伯小乐 网商动力

Executors 6种线程池创建

Executors 6种线程池创建

1.newFixedThreadPool:创建一个固定大小的线程池

		ExecutorService threadPool= Executors.newFixedThreadPool(5);
        //2.使用线程池执行任务一
        for (int i=0;i<5;i++){
            //给线程池添加任务
            threadPool.submit(new Runnable() {
                @Override
                public void run() {
                    System.out.println("线程名"+Thread.currentThread().getName()+"在执行任务1");
                }
            });
        }

2.newSingleThreadExecutor:创建单个线程的线程池

        ExecutorService service= Executors.newSingleThreadExecutor();
        for (int i=0;i<5;i++){
            int finalI = i;
            service.submit(()->{
                System.out.println(finalI +"线程名"+Thread.currentThread().getName());//CPU只创建了1个线程,名称始终一样
            });
        }

3.newSingleThreadScheduledExecutor:创建执行定时任务的单个线程的线程池

		ScheduledExecutorService service= Executors.newSingleThreadScheduledExecutor();
        System.out.println("添加任务:"+ LocalDateTime.now());
        service.schedule(new Runnable() {
            @Override
            public void run() {
                System.out.println("执行任务:"+LocalDateTime.now());
            }
        },3,TimeUnit.SECONDS);//推迟3秒执行任务

4.newScheduledThreadPool:创建执行定时任务的线程池

		ScheduledExecutorService service = Executors.newScheduledThreadPool(5);//5个线程
        System.out.println("添加任务:" + LocalDateTime.now());
        //单独方法
        once(service);
        
 public static void once(ScheduledExecutorService service) {
 		//service里有多个方法具体不详细阐述,看源码
        service.schedule(new Runnable() {
            @Override
            public void run() {
                System.out.println("执行任务:" + LocalDateTime.now());
            }
        }, 3, TimeUnit.SECONDS);//推迟3秒执行
    }

5.newCachedThreadPool:带缓存的线程池,适用于短时间有大量任务的场景,但有可能会占用更多的资源;线程数量随任务量而定。

        ExecutorService service= Executors.newCachedThreadPool();
        //有50个任务
        for(int i=0;i<50;i++){
            int finalI = i;
            service.submit(()->{
                System.out.println(finalI +"线程名"+Thread.currentThread().getName());//线程名有多少个,CPU就创建了多少个线程
            });
        }

6.newWorkStealingPool:创建一个抢占式执行的线程池(任务执行顺序不确定),注意此方法只有在 JDK 1.8+ 版本中才能使用

        ExecutorService executorService = Executors.newWorkStealingPool();
        for (int i = 0; i < 50; i++) {
            int finals = i;
            executorService.submit(()->{
                System.out.println(finals + "线程名" + Thread.currentThread().getName());
            });
        }
转载请注明:文章转载自 www.mshxw.com
本文地址:https://www.mshxw.com/it/874633.html
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

版权所有 (c)2021-2022 MSHXW.COM

ICP备案号:晋ICP备2021003244-6号