java线程池创建线程

原创admin 分类：热门问答 2024-04-29 20:36:39 0

java线程池创建线程
在Java多线程编程中，线程池是一个非常重要的概念。线程池允许我们重用已经创建的线程，减少在程序中频繁创建和销毁线程的开销。通过线程池，我们可以更好地控制并发的线程数量，提高程序的响应速度和效率。

线程池的定义与目的

线程池是一种执行器（Executor），用于在一个后台线程中执行任务。线程池的主要目的是减少在创建和销毁线程时所产生的性能开销。通过重用已经创建的线程来执行新的任务，线程池提高了程序的响应速度，并且提供了更好的系统资源管理。

线程池与单线程的对比

线程池与单线程执行器的主要区别在于并发控制。单线程执行器一次只能执行一个任务，而线程池可以同时执行多个任务。以下是线程池和单线程执行器的对比表格：

对比项	线程池	单线程执行器
并发数	可配置，支持多线程并发执行	固定为1，只能串行执行任务
资源利用	高，能有效利用系统资源	低，资源利用率不高
任务处理	可以同时处理多个任务	一次只能处理一个任务
创建销毁开销	低，线程复用	高，频繁创建和销毁线程
适用场景	需要同时处理大量任务的场景	任务之间存在依赖，需要串行处理

核心类与方法

Java线程池的核心类是java.util.concurrent.ThreadPoolExecutor，它提供了线程池的配置和任务执行的接口。以下是一些重要的方法：

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 = 5; // 线程池大小
        ThreadPoolExecutor executor = (ThreadPoolExecutor) Executors.newFixedThreadPool(poolSize);

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

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

案例二：单线程线程池

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

public class SingleThreadExecutorExample {
    public static void main(String[] args) {
        ThreadPoolExecutor executor = (ThreadPoolExecutor) Executors.newSingleThreadExecutor();

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

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

参数名	描述
corePoolSize	线程池保留的最小线程数
maximumPoolSize	线程池最大线程数
keepAliveTime	非核心线程空闲时的存活时间
unit	keepAliveTime参数的时间单位
workQueue	阻塞队列，用于存放待执行任务
threadFactory	用于创建新线程的工厂
rejectedExecutionHandler	任务太多时，无法执行的任务的处理策略