百度360必应搜狗淘宝本站头条
当前位置:网站首页 > 技术资源 > 正文

Java 线程池创建方式大揭秘!互联网大厂后端开发必看

moboyou 2025-06-05 16:49 3 浏览

你在互联网大厂做后端开发时,在使用 Java 线程池方面,有没有遇到过不知道该怎么创建的情况呢?项目需求一来,多线程任务一布置,线程池该如何正确创建,成了很多开发者头疼的问题。今天,咱们就深入聊聊 Java 中线程池的创建方式,帮你彻底解决这个困扰!

互联网大厂后端开发为什么离不开线程池?

在互联网大厂的后端开发场景中,高并发、大数据量处理是家常便饭。以电商平台的大促活动为例,海量用户同时下单、查询订单信息,服务器需要同时处理成千上万的请求。这时候,线程池就显得尤为重要。如果没有合理使用线程池,要么创建过多线程导致资源耗尽,服务器崩溃;要么线程数量不足,任务堆积,用户等待时间过长,严重影响用户体验。而且,Java 作为互联网后端开发的主流语言之一,其线程池机制是保障程序高效稳定运行的关键。但很多开发者对于线程池的创建,仅仅停留在一知半解的层面,这就很容易在实际开发中埋下隐患。

Java 线程池创建方式详解

Java 中线程池的创建方式主要有以下几种:

使用 Executors 工厂类创建

FixedThreadPool

通过
Executors.newFixedThreadPool(int nThreads)方法创建,它会创建一个固定大小的线程池,池中线程数量固定不变。当有新任务提交时,如果线程池中有空闲线程,就会立即执行任务;如果没有空闲线程,任务会被暂存到一个阻塞队列中,等待有线程空闲时再执行。

示例:假设我们有一个电商订单处理系统,需要同时处理 10 个订单的支付请求,每个支付请求都需要一个线程来处理。为了避免线程过多导致资源竞争,我们可以使用 FixedThreadPool 来创建一个固定大小为 10 的线程池。

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

public class FixedThreadPoolExample {
    public static void main(String[] args) {
        ExecutorService executorService = Executors.newFixedThreadPool(10);
        for (int i = 0; i < 20; i++) {
            final int orderId = i;
            executorService.submit(() -> {
                // 模拟处理订单支付逻辑
                System.out.println("处理订单 " + orderId + " 的支付请求");
            });
        }
        executorService.shutdown();
    }
}

这种线程池适用于处理固定数量并发任务的场景,比如数据库连接池,保证固定数量的线程同时访问数据库,避免资源竞争。

CachedThreadPool

使用
Executors.newCachedThreadPool()创建,它是一个可缓存的线程池。如果线程池长度超过处理需求,可灵活回收空闲线程,若无可回收,则新建线程。它比较适合处理执行时间短、突发性大量请求的任务。

示例:在一个日志收集系统中,会不定期有大量的日志记录任务产生。我们可以使用 CachedThreadPool 来处理这些任务。

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

public class CachedThreadPoolExample {
    public static void main(String[] args) {
        ExecutorService executorService = Executors.newCachedThreadPool();
        for (int i = 0; i < 100; i++) {
            final int logId = i;
            executorService.submit(() -> {
                // 模拟记录日志逻辑
                System.out.println("记录日志 " + logId);
            });
        }
        executorService.shutdown();
    }
}

任务执行完线程就可以被回收,下次有新任务再来时又能快速创建新线程处理。

SingleThreadExecutor

通过
Executors.newSingleThreadExecutor()创建,它只有一个工作线程来执行任务。所有任务按照提交顺序依次执行,保证任务执行的顺序性。

示例:在文件按顺序读写操作的场景中,使用 SingleThreadExecutor 能确保数据的读写顺序。比如,我们要按顺序读取一系列文本文件的内容。

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

public class SingleThreadExecutorExample {
    public static void main(String[] args) {
        ExecutorService executorService = Executors.newSingleThreadExecutor();
        String[] fileNames = {"file1.txt", "file2.txt", "file3.txt"};
        for (String fileName : fileNames) {
            final String name = fileName;
            executorService.submit(() -> {
                // 模拟按顺序读取文件内容逻辑
                System.out.println("读取文件 " + name + " 的内容");
            });
        }
        executorService.shutdown();
    }
}

ScheduledThreadPool

使用
Executors.newScheduledThreadPool(int corePoolSize)创建,它可以实现定时任务和周期性任务的执行。

示例:在电商系统中,每天凌晨 2 点需要统计前一天的销售数据。我们可以使用 ScheduledThreadPool 来实现这个定时任务。

import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit;

public class ScheduledThreadPoolExample {
    public static void main(String[] args) {
        ScheduledExecutorService scheduledExecutorService = Executors.newScheduledThreadPool(1);
        scheduledExecutorService.scheduleAtFixedRate(() -> {
            // 模拟统计销售数据逻辑
            System.out.println("统计销售数据");
        }, 0, 1, TimeUnit.DAYS);
    }
}

通过schedule()方法可以延迟执行任务,scheduleAtFixedRate()和scheduleWithFixedDelay()方法可以实现周期性任务的执行。

通过 ThreadPoolExecutor 类手动创建

ThreadPoolExecutor 是创建线程池的核心类,通过它我们可以更灵活地配置线程池的参数。它的构造函数如下:

public ThreadPoolExecutor(int corePoolSize,
                          int maximumPoolSize,
                          long keepAliveTime,
                          TimeUnit unit,
                          BlockingQueue<Runnable> workQueue,
                          ThreadFactory threadFactory,
                          RejectedExecutionHandler handler)
  • corePoolSize:核心线程数,线程池创建后默认会创建的线程数量,即使这些线程处于空闲状态,也不会被销毁(除非设置了allowCoreThreadTimeOut为true)。
  • maximumPoolSize:最大线程数,线程池中允许存在的最大线程数量。当任务队列满了且工作线程数小于最大线程数时,线程池会创建新的线程来处理任务。
  • keepAliveTime:空闲线程的存活时间。当线程池中的线程数量大于核心线程数时,如果某个线程空闲时间超过keepAliveTime,就会被销毁,直到线程池中的线程数量等于核心线程数。
  • unit:keepAliveTime的时间单位,如TimeUnit.MILLISECONDS(毫秒)、TimeUnit.SECONDS(秒)等。
  • workQueue:任务队列,用于存放等待执行的任务。常见的有ArrayBlockingQueue(有界队列)、LinkedBlockingQueue(无界队列)等。
  • threadFactory:线程工厂,用于创建线程,一般使用默认的线程工厂即可,也可以自定义线程工厂来设置线程的名称、优先级等属性。
  • handler:拒绝策略,当任务队列已满且线程数达到最大线程数时,新提交的任务会被拒绝,此时就需要通过拒绝策略来处理这些被拒绝的任务。常见的拒绝策略有AbortPolicy(抛出异常)、CallerRunsPolicy(在调用者线程中执行任务)、DiscardPolicy(丢弃任务)、DiscardOldestPolicy(丢弃队列中最老的任务,然后重新提交当前任务)。

示例:我们创建一个线程池,核心线程数为 5,最大线程数为 10,空闲线程存活时间为 60 秒,任务队列使用有界的ArrayBlockingQueue,容量为 20,拒绝策略采用CallerRunsPolicy。

import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.BlockingQueue;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;

public class ThreadPoolExecutorExample {
    public static void main(String[] args) {
        BlockingQueue<Runnable> workQueue = new ArrayBlockingQueue<>(20);
        ThreadPoolExecutor threadPoolExecutor = new ThreadPoolExecutor(
                5,
                10,
                60,
                TimeUnit.SECONDS,
                workQueue,
                new ThreadPoolExecutor.CallerRunsPolicy()
        );
        for (int i = 0; i < 50; i++) {
            final int taskId = i;
            threadPoolExecutor.submit(() -> {
                // 模拟任务执行逻辑
                System.out.println("执行任务 " + taskId);
            });
        }
        threadPoolExecutor.shutdown();
    }
}

手动创建线程池虽然相对复杂,但却能让我们根据具体的业务场景,精准地配置各项参数,以达到最佳的性能和资源利用效果。

总结

以上就是 Java 中线程池常见的创建方式。在互联网大厂后端开发中,掌握这些创建方式,合理配置线程池参数,能让你的程序在高并发场景下更加稳定、高效地运行。希望大家都能熟练运用线程池,在项目开发中少踩坑!如果你在实际使用线程池的过程中有任何问题,或者有独特的经验,欢迎在评论区留言分享,咱们一起交流探讨,共同进步!

相关推荐

python多线程实现查找目录下有没有相同哈希值的文件

python多线程实现查找目录下有没有相同的文件,列出哈希值相同的文件importosimporthashlibfromconcurrent.futuresimportThreadPoo...

Java、Go 和 Python 多线程性能对比

大家好,我是难瓜。今天分享多线程下这三门语言的表现。简介在计算机中,线程是可以由处理器独立执行的小指令序列。多线程在一个进程中是可能的,其中它们共享资源,例如指令和上下文。发现在运行多线程进程时效率最...

干货分享丨Python多线程之_thread与threading模块

在Python程序中,多线程的应用程序会创建一个函数,来执行需要重复执行多次的程序代码,然后创建一个线程执行该函数。一个线程是一个应用程序单元,用于在后台并行执行多个耗时的动作。在多线程的应用程序中,...

一文带您了解Python中的并发:异步(Asyncio)和多线程(Thread)

Python以其简单性和多样性而闻名,是一种适用于广泛应用领域的编程语言。在处理多个任务并发时,Python提供了两种主要方法:Asyncio用于异步编程,Multithreading用于管理多个...

解锁Python并发编程:多线程和多进程的神秘面纱揭晓

欢迎来到我们的系列博客《Python全景系列》!在这个系列中,我们将带领你从Python的基础知识开始,一步步深入到高级话题,帮助你掌握这门强大而灵活的编程语法。无论你是编程新手,还是有一定基础的开发...

Python多线程-基础篇

一、多线程相关概念1.并发和并行的区别并发和并行是即相似又有区别的两个概念,并行是指两个或者多个事件在同一时刻同时执行,而并发是指两个或多个事件通过时间片轮流被执行。从计算机工作原理的角度出发,“并发...

PYTHON多线程实现web服务器httpserver实例

PYTHON多线程实现web服务器importhttp.serverimportsocketserverimportthreading#服务器监听的端口PORT=8000#...

如何编写Python漏洞验证脚本(单线程和多线程)

我们实战经常会遇到以下几个问题:1、遇到一个利用步骤十分繁琐的漏洞,中间错一步就无法利用2、挖到一个通用漏洞,想要批量刷洞小赚一波,但手动去测试每个网站工作量太大这个时候编写一个poc脚本将会减轻...

Python 多线程高频面试题,直接把这些答案“甩在”面试官脸上

点赞、收藏、加关注,下次找我不迷路不管你是刚入行的新手,还是有一定经验的开发者,掌握多线程的核心问题,都能让你在面试中脱颖而出。今天咱就来盘一盘5个高频的Python多线程面试题,用通俗易懂...

python多进程和多线程的使用和对比

介绍多线程和多进程是常见的并发编程模型,它们被广泛应用于各种类型的应用程序中。在本文中,我将就Python多线程和多进程进行详细的对比。首先,让我们来看一下Python多线程。多线程是一种并发编程模型...

24-3-Python多线程-线程队列-queue模块

3-1-概念queue模块提供了多线程编程中的队列实现,队列是线程安全的数据结构,能在多线程环境下安全地进行数据交换。3-2-queue的队列类型Queue(先进先出队列)、LifoQueue(后进...

玩蛇(Python) - 并发编程之多线程

一、线程简介线程(thread)是操作系统能够进行运算调度的最小单位。它被包含在进程之中,是进程中的实际运作单位。由于线程是操作系统直接支持的执行单元,因此,高级语言通常都内置多线程的支持,Pytho...

Python多进程与多线程应用场景对比

在Python中,多进程(Multiprocessing)和多线程(Multithreading)的选择取决于任务类型(I/O密集型vsCPU密集型)、Python的GIL限制以及并...

Python多线程,守护线程和非守护线程,线程的join方法,代码案例

守护线程和非守护线程守护线程&&非守护线程守护线程,是和主线程一起结束的线程,叫守护线程,非守护线程,主线程的结束不影响该线程的执行,主线程结束非守护线程不会立刻结束,也叫用户线程。Python的守护...

Python3中最常用的5种线程锁你会用吗

前言本章节将继续围绕threading模块讲解,基本上是纯理论偏多。对于日常开发者来讲很少会使用到本章节的内容,但是对框架作者等是必备知识,同时也是高频的面试常见问题。私信小编01即可获取大量Pyth...