当前位置：首页 > news >正文

JAVA:线程池

news 2025/4/29 15:34:10

我们了解到因为频繁创建销毁进程的开销较大，就出现了线程，但是，又觉得频繁创建线程的开销也不小，就出现了线程池；减少每次创建、销毁线程的损耗

概念

一种并发编程的常用技术，用于管理与重用线程，它由线程池管理器、工作队列和线程池线程组成

线程池是在应用程序启动时创建一定数量的线程，并把它们保存在线程池中。当有任务需要执行时

在线程池中获取到一个空闲的线程，将任务分配给它执行，任务执行完后再把线程返回到线程池，以供下次使用。

线程池的创建

标准库中提供了线程池的创建方式 - Executors

submit(Runnable) 方法：通过 Runnable 描述一段要执行的任务，通过 submit 任务放到线程池中，此时线程池的线程就会执行 Runnable 里的任务。

newFixedThreadPool：创建固定数量的线程池

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;public class ThreadDemo1 {//创建固定数量的线程池public static void main(String[] args) {ExecutorService pool= Executors.newFixedThreadPool(10);for (int i = 0; i < 10; i++) {pool.submit(new Runnable(){@Overridepublic void run() {System.out.println("Hello!");}});}pool.shutdown();}
}

newCachedThreadPool：创建线程数目动态增长的线程池

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;public class ThreadDemo2 {public static void main(String[] args) {ExecutorService pool= Executors.newCachedThreadPool();for(int i=0;i<20;i++){//可以调整数字进行测试pool.submit(new Runnable() {@Overridepublic void run() {System.out.println("你好");}});}pool.shutdown();}}

newSingleThreadExecutor：创建只包含单个的线程池

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;public class ThreadDemo3 {public static void main(String[] args) {ExecutorService pool= Executors.newSingleThreadExecutor();for(int i=0;i<5;i++){pool.submit(new Runnable() {@Overridepublic void run() {System.out.println(Thread.currentThread().getName()+" Hello");}});}pool.shutdown();}
}

newScheduledThreadPool：设定延迟时间后执行命令，或者定期执行命令


import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit;public class ThreadDemo4 {public static void main(String[] args) {//创建一个具有5个核心线程的线程池ScheduledExecutorService pool= Executors.newScheduledThreadPool(5);pool.schedule(()->{System.out.println("hello");},3, TimeUnit.SECONDS);//提交一个任务，此任务将在三秒后执行pool.shutdown();}
}

Executors 本质上是 ThreadPoolExecutor 类的封装

ThreadPoolExecutor 提供很多参数供程序员需求去选择，可以具体细化线程池的行为设定