java创建线程池代码

原创admin 分类：热门问答 2024-04-29 17:22:47 0

java创建线程池代码
在Java中，线程池是一种执行器（Executor），用于在一个后台线程中执行任务。它主要用来减少在创建和销毁线程时所产生的性能开销。线程池的核心优势在于能够有效控制并发的线程数量，重用已经创建的线程来执行新的任务，以及提供线程的管理工作。

线程池的定义与目的

线程池的核心概念是线程复用和任务调度。相比于每次执行任务都创建新线程，线程池通过复用已存在的空闲线程来减少资源消耗。此外，线程池还能够提供定时执行、线程优先级控制等功能。

线程池与单线程的对比

线程池与单线程执行器的主要区别在于并发控制和资源管理。以下是两者的对比表格：

对比项	线程池	单线程执行器
并发控制	可控制最大并发数	一次只能执行一个任务
资源消耗	资源消耗较低，线程可复用	每次任务都需要创建新线程，资源消耗高
任务管理	可以进行任务调度和管理	任务管理能力较弱
使用场景	适用于大量并发任务	适用于需要顺序执行的任务
灵活性	高，可以根据需求调整线程数量	低

线程池的核心类与方法

Java线程池主要由java.util.concurrent包中的ThreadPoolExecutor和ScheduledThreadPoolExecutor类实现。以下是一些核心方法：

execute(Runnable command): 执行一个任务。
submit(Runnable task): 提交一个任务并返回一个Future对象。
shutdown(): 平滑地关闭线程池，不再接受新任务，但已提交的任务仍会执行。
shutdownNow(): 尝试立即停止所有正在执行的任务，并暂停处理等待的任务，并返回等待执行的任务列表。

线程池的使用场景

线程池适用于需要执行大量短期异步任务的场景，例如Web服务器处理并发请求、数据库连接池管理、并行处理任务等。

代码案例

以下是两个创建线程池的代码案例：

案例一：固定大小的线程池

import java.util.concurrent.Executors;
import java.util.concurrent.ThreadPoolExecutor;

public class FixedThreadPoolExample {
    public static void main(String[] args) {
        int poolSize = 10; // 线程池大小
        ThreadPoolExecutor executor = (ThreadPoolExecutor) Executors.newFixedThreadPool(poolSize);

        for (int i = 0; i < 50; i++) {
            int finalI = i;
            executor.execute(() -> {
                System.out.println("Task " + finalI + " is running by " + Thread.currentThread().getName());
            });
        }

        executor.shutdown(); // 关闭线程池，不再接受新任务
    }
}

案例二：单线程的线程池

import java.util.concurrent.Executors;

public class SingleThreadExecutorExample {
    public static void main(String[] args) {
        java.util.concurrent.ExecutorService executor = Executors.newSingleThreadExecutor();

        for (int i = 0; i < 50; i++) {
            int finalI = i;
            executor.execute(() -> {
                System.out.println("Task " + finalI + " is running by " + Thread.currentThread().getName());
            });
        }

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

补充知识表格

以下是线程池相关的重要参数和它们的作用：

参数	作用
corePoolSize	线程池保留的最小线程数，即使它们处于空闲状态
maximumPoolSize	线程池最大线程数
keepAliveTime	当线程池数量超过`corePoolSize`时，多余的空闲线程能等待多久终止
unit	`keepAliveTime`参数的时间单位
workQueue	阻塞队列，用于存放待执行任务
threadFactory	用于创建新线程的工厂
handler	拒绝策略，当任务太多，无法被线程池及时处理时的策略