线程池的创建方式

线程池的创建方式:

1、newCachedThreadPoo:

创建一个可缓存的线程池,当线程池的线程数量超过任务数量时,自动回收空闲线程,当线程当任务数量超过线程池的线程数量时,自动添加新线程;

ExecutorService executor = Executors,newCachedThreadPool();
for (int i = 0;i < 10; i++) {
    //模拟10个任务
    executor.submit(new Runnable() {
        @Override
        public void run() {
			// 线程执行的代码
        }
    });
executor.shutdown () ;

2、newFixedThreadPool(int n)

创建一个固定大小的线程池,线程数量固定为n,当任务数量超过线程池的线程数量时,任务会被放在任务队列中等待执行。

ExecutorService executor = Executors.newFixedThreadPool(5);
for (int i = 0; i< 10; i++) {
    //模拟10个任务
    executor.submit (new Runnable () {
        @Override
		public void run() {
            // 线程执行的代码
        }    
    });
}
executor.shutdown () ;

3、newSingleThreadExecutorl :

创建一个单线程的线程池,所有任务都在同一个线程中,顺序执行。

ExecutorService executor = Executors.newSingleThreadExecutor();
for (int i = 0;< 10; i++) {
//模拟10个任务
executor.submit (new Runnable(){ 
@Override
public void run() {
	// 线程执行的代码
	}
 });
}
executor.shutdown ();

4、newScheduledThreadPool(int corePoolSize)

ScheduledExecutorService executor =Executors.newScheduledThreadPoo1(2);
for (int i = 0;i < 10; i++) {
//模拟10个任务
executor.schedule(new Runnable () {
		@Override
		public void run{
		// 线程执行代码
		
	} 

	},5,TimeUnit.SECONDS);
}
executor.shutdown () ;

建一个定时任务的线程池,可以在指定的时间间隔内周期性的执行任务,在阿里巴巴这么开发手册中,建议开发者手动创建线程。

[强制]线程池不允许使用 Executors 去创建,而是通过ThreadPoolExecutor的方式,这4样的处理方式让写的同学更加明确线程池的运行规则,规避资源耗尽的风险。
说明: Executors 返回的线程池对象的弊端如下

1)FixedThreadPool和 SinaleThreadPool :
允许的请求队列长度为 Integer.MAX_VALUE,可能会堆积大量的请求,从而导致 OOM

2)CachedThreadPool :
允许的创建线程数量为 Integer.MAX_VALUE,可能会创建大量的线程,从而导致 OOM

这是因为Executors工具类虽然提供了一些便利的方法来创建线程池,这些方法并没有很好的考虑到线程池的使用场景和实际需求,容易导致线程池的滥用。进而引发各种问题;

我们可以通过ThreadPoolExecutor手动创建:

自定义设置参数:

corePoolSize :线程池的核心线程数,即在没有任务需要执行时线程池的大小

maximumPoolSize:线程池最大能够容纳的线程数,当线程池的工作队列已满并且仍有新的任务到来时,线程池就会创建新的线程,直到达到该参数指定的上限;

keepAliveTime: 当线程池中线程数量超过核心线程数时,这时多余的空闲线程在终止之前等待新任务的最长时间

unit,keepAliveTime:参数的时间单位

workQueue:任务队列,用于存放等待执行的任务

threadFactory:线程工厂,用于创建新线程的工厂

handler:拒绝策略,当线程池无法处理新任务时的处理方式

ExecutorService threadPool = new ThreadPoolExecutor(
			2,// 核心线程数
			10,// 最大线程数
			2L,//空闲线程存活时间
			TimeUnit.SECONDS,// 空闲线程活跃时间单位
			new LinkedBlockingQueue<Runnable>(5),// 线程池任务队列
			Executors.defaultThreadFactory()// 默认线程工厂
			new ThreadPoolExecutor.AbortPolicy() // 拒绝策略
    );
		try {
            for (int i = 0;< 10; i++) { // 模拟10个用户来办理业务
                threadPool.execute(() ->{
                   // 线程要执行的任务; 
                });
        }
	} catch (Exception e) {
            e.printstackTrace() ;
        } finally {
            threadPool.shutdown(); // 关闭线程池
        }

相关推荐

  1. 线创建方式

    2024-04-21 02:32:05       40 阅读
  2. 创建线方式

    2024-04-21 02:32:05       35 阅读
  3. 线创建方式

    2024-04-21 02:32:05       34 阅读

最近更新

  1. docker php8.1+nginx base 镜像 dockerfile 配置

    2024-04-21 02:32:05       94 阅读
  2. Could not load dynamic library ‘cudart64_100.dll‘

    2024-04-21 02:32:05       100 阅读
  3. 在Django里面运行非项目文件

    2024-04-21 02:32:05       82 阅读
  4. Python语言-面向对象

    2024-04-21 02:32:05       91 阅读

热门阅读

  1. 用爬石玩转石墨文档

    2024-04-21 02:32:05       48 阅读
  2. 程序员写付费专栏

    2024-04-21 02:32:05       40 阅读
  3. vue 数据类型转换

    2024-04-21 02:32:05       40 阅读
  4. oracle rman的大小不一定比segment的大小大

    2024-04-21 02:32:05       44 阅读
  5. 力学笃行(五)Qt QWidgets类

    2024-04-21 02:32:05       193 阅读
  6. Vue08天禹老师主讲

    2024-04-21 02:32:05       110 阅读
  7. R:UpSet韦恩图制作

    2024-04-21 02:32:05       71 阅读
  8. Linux命令学习—DNS 服务器

    2024-04-21 02:32:05       39 阅读
  9. Linux下多版本cuda切换

    2024-04-21 02:32:05       41 阅读