线程池及线程调度

蚀月接口
• 阅读 141

一、概述
Java中的线程池是运用场景最多的并发框架,几乎所有需要异步或并发执行任务的程序都可以使用线程池。线程池内部提供了一个线程队列,队列中保存着所有等待状态的线程,在开发过程中,合理地使用线程池能够带来以下3个好处:

第一:降低资源消耗。通过重复利用已创建的线程降低线程创建和销毁造成的消耗。

第二:提高响应速度。当任务到达时,任务可以不需要等到线程创建就能立即执行。

第三:提高线程的可管理性。线程是稀缺资源,如果无限制地创建,不仅会消耗系统资源,还会降低系统的稳定性,使用线程池可以进行统一分配、调优和监控。

二、线程池的体系结构

三、Executors 工具类
Executors 具有许多工厂方法,可以很方便的创建线程池,下面是其常用的几个创建线程池的方法:

下面演示一下Executors工具类的使用,具体代码如下所示:

public class TestThreadPool {

        public static void main(String[] args) {

                // 1. 创建具有5个线程的线程池
                ExecutorService threadPool = Executors.newFixedThreadPool(5);

                // 2. 为线程池中的线程分配任务
                ThreadPoolDemo tpd = new ThreadPoolDemo();
                for (int i = 0; i < 10; i++) {
                        threadPool.submit(tpd);
                }

                // 3. 关闭线程池
                threadPool.shutdown();
        }

}

class ThreadPoolDemo implements Runnable {

        @Override
        public void run() {
                try {
                        Thread.sleep(100);
                } catch (InterruptedException e) {
                        e.printStackTrace();
                }
                System.out.println(Thread.currentThread().getName());
        }

}

运行结果如下所示:

pool-1-thread-1
pool-1-thread-2
pool-1-thread-4
pool-1-thread-3
pool-1-thread-5
pool-1-thread-1
pool-1-thread-2
pool-1-thread-3
pool-1-thread-4
pool-1-thread-5

由运行结果可知,线程池中的5个线程都执行了打印其线程名的任务。

四、线程调度
线程池的体系结构中,ExecutorService 接口具有一个 ScheduledExecutorService 的子接口。该接口负责线程的调度,我们可以使用工具类的Executors 的 newScheduleThreadPool 方法来创建固定大小的线程池,它可以延迟或定时的执行任务,多数情况下可用来替代Timer类。

下面演示ScheduledExecutorService 接口的线程池线程延迟调度执行的事例,具体代码如下:

public class TestScheduleThreadPool {

        public static void main(String[] args) throws Exception {
                // 1. 创建可进行线程调度的固定大小的线程池
                ScheduledExecutorService pool = Executors.newScheduledThreadPool(5);

                // 2. 创建5个线程,每个线程延迟1秒打印一次,并将随机数结果返回再打印
                for (int i = 0; i < 5; i++) {
                        ScheduledFuture<Integer> result = pool.schedule(new Callable<Integer>() {

                                @Override
                                public Integer call() throws Exception {
                                        int num = (int) (Math.random() * 101);
                                        System.out.println(Thread.currentThread().getName() + " : " + num);
                                        return num;
                                }
                        }, 1, TimeUnit.SECONDS);

                        System.out.println(result.get());
                }

                // 3. 关闭线程池
                pool.shutdown();
        }
}

点赞
收藏
评论区
推荐文章
Wesley13 Wesley13
3年前
java 面试知识点笔记(十三)多线程与并发
java线程池,利用Exceutors创建不同的线程池满足不同场景需求:1.newSingleThreadExecutor() 创建一个单线程的线程池。这个线程池只有一个线程在工作,也就是相当于单线程串行执行所有任务。如果这个唯一的线程因为异常结束,那么会有一个新的线程来替代它。此线程池保证所有任务的执行顺序按照任务的提交顺序执行。2.
Wesley13 Wesley13
3年前
java_线程池
血一样的教训,今天上午参加了一家现场面试java。在这之前,我一直认为我的java基础还是可以的,而今天一问三不知。现在将面试的问题整理出来一、说说java中的线程池?  1.线程池:线程池是线程的集合,不用自己创建线程,把线程直接给线程池,由线程池处理。   2.过程:首先,使用线程池可以重复利用已有的线程继续执行任务,避免线程在
Wesley13 Wesley13
3年前
java四大线程池
一、为什么需要使用线程池  1、减少了创建和销毁线程的次数,每个工作线程都可以被重复利用,可执行多个任务。2、可以根据系统的承受能力,调整线程池中工作线线程的数目,防止因为消耗过多的内存,而把服务器累趴下(每个线程需要大约1MB内存,线程开的越多,消耗的内存也就越大,最后死机)。Java中创建和销毁一个线程是比较
zdd小小菜鸟 zdd小小菜鸟
2年前
多线程面试
多线程篇1.为什么要使用线程池tex避免频繁地创建和销毁线程,达到线程对象的重用。另外,使用线程池还可以根据项目灵活地控制并发的数目。2.java中如何获取到线程dump文件tex死循环、死锁、阻
Wesley13 Wesley13
3年前
JAVA多线程学习
Java通过Excutors提供四种线程池:newCachedThreadPool        创建一个可缓存线程池,如果线程池长度超过处理需要,可灵活回收空闲线程,若无可回收,则新建线程。newFixedThreadPool        创建一个定长线程,可控制线程最大并发数
Stella981 Stella981
3年前
Executors相关的类(线程池)
一、概述Java是天生就支持并发的语言,支持并发意味着多线程,线程的频繁创建在高并发及大数据量是非常消耗资源的,因为java提供了线程池。在jdk1.5以前的版本中,线程池的使用是及其简陋的,但是在JDK1.5后,有了很大的改善。JDK1.5之后加入了java.util.concurrent包,java.util.concurrent包的加入给
Wesley13 Wesley13
3年前
Java多线程编程
  在计算机中,线程是稀缺资源,创建过多的线程,不仅会消耗系统资源,还会降低系统的稳定性,合理的使用线程池对线程进行统一分配、调优和监控,有以下好处:降低资源消耗;提高响应速度;提高线程的可管理性。  Java多线程编程常用到多线程框架Executor,使用此框架可以方便、高效的对线程进行管理,我们先了解下Executor
Wesley13 Wesley13
3年前
Java通过Executors提供四种线程池
Java通过Executors提供四种线程池,分别为:newCachedThreadPool创建一个可缓存线程池,如果线程池长度超过处理需要,可灵活回收空闲线程,若无可回收,则新建线程。newFixedThreadPool创建一个定长线程池,可控制线程最大并发数,超出的线程会在队列中等待。newScheduledThreadPool创建
Wesley13 Wesley13
3年前
Java 基础知识(七)
1.创建线程池1)newCacheThreadPool 创建一个可缓存的线程池,如果线程池长度超过处理需要,可灵活回收空闲线程,若无可回收,则新建线程 2)newFixedThreadPool  创建一个定长线程池,可控制线程最大并发数,超出的线程会在队列中等待 3)newScheduledThreadPool  创建一个定长线程池,支持
Wesley13 Wesley13
3年前
Java中的线程池
java中的线程池是运用场景最多的并发框架,几乎所有需要异步或并发执行任务的程序都可以使用线程池。在开发过程中,合理使用线程池能够带来三个好处。第一:降低资源消耗。通过重复利用已创建的线程降低线程创建和销毁造成的消耗。第二:提高响应速度。当任务到达时,任务可以不需要等到线程创建就能立即执行。第三:提高线程的可管理性。线程是稀缺
ThreadPoolExecutor线程池内部处理浅析 | 京东物流技术团队
我们知道如果程序中并发的线程数量很多,并且每个线程都是执行一个时间很短的任务就结束时,会因为频繁创建线程而大大降低系统的效率,因此出现了线程池的使用方式,它可以提前创建好线程来执行任务。本文主要通过java的ThreadPoolExecutor来查看线程池
蚀月接口
蚀月接口
Lv1
惊鸿一瞥而后不知所踪,这大概就是晚霞的美之所在。
文章
5
粉丝
0
获赞
0