JAVA多线程——线程池的使用

tech2026-01-22  5

JAVA多线程——线程池的使用

问题:经常创建和销毁使用量特别大的资源时,比如并发情况下的线程,对性能影响很大。

解决:提前创建好多个线程,放入线程池中,使用时直接获取,使用完放回池中。可以避免频繁创建和销毁、实现重复利用。

好处:

提高响应速度(减少了创建新线程的时间)

减低资源消耗(重复利用线程池中的线程)

便于线程管理

可以设置线程池的属性

corePoolSize:核心池的大小

maximumPoolSize: 最大线程数

keepAliveTime:线程没有任务时最多保持多久时间后会终止

ExecutorService线程池接口

Executors:工具类,用于创建并返回不同类型的线程池

Executors.newFixedThreadPool(n);创建一个可重用固定线程数的线程池Executors.newCachedThreadPool();创建一个可根据需要创建新线程的线程池Executors.newSingleThreadExecutor();创建一个只有一个线程的线程池Executors.newScheduledThreadPool(n);创建一个线程池,它可安排在给定延迟后运行命令或定期的执行 package com.peng.demon06; import java.util.concurrent.Executor; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; import java.util.concurrent.ThreadPoolExecutor; //测试线程池 public class TestPool { public static void main(String[] args) { //ExecutorService线程池接口 Executors:工具类,用于创建并返回不同类型的线程池 //创建指定线程数量线程池 ExecutorService service = Executors.newFixedThreadPool(10); //上面返回的对象service不是接口的对象,因为接口没有对象,返回的是接口的实现类的对象 //把service进行类型强制转换 ThreadPoolExecutor service1 = (ThreadPoolExecutor)service; //设置线程池的属性 因为ExecutorService是线程池接口,里面的属性为常量,所以如果要设置属性就要在接口的实现类中设置 System.out.println(service.getClass());//获取service对象是哪个类造的 ThreadPoolExecutor service1.setCorePoolSize(16);//设置核心池的大小 service1.setMaximumPoolSize(20);//设置最大线程数 //把线程放入创建的执行服务里 //执行指定的线程操作,需要提供实现Runnable接口或Callable接口的实现类对象 service.execute(new MyThread());//线程1输出偶数 //execute方法:执行任务/命令,没有返回值,一般用来执行Runnable service.execute(new MyThread1());//线程2输出奇数 service.execute(new MyThread1());//线程3输出奇数 //关闭连接 service.shutdown(); } } class MyThread implements Runnable{ @Override public void run() { for (int i = 0; i <= 20; i++) { if (i % 2 == 0){ System.out.println(Thread.currentThread().getName()+":"+i); } } } } class MyThread1 implements Runnable{ @Override public void run() { for (int i = 0; i <=20; i++) { if (i % 2 != 0){ System.out.println(Thread.currentThread().getName()+":"+i); } } } }

使用线程池也是创建线程的第四种方式

最新回复(0)