详谈Java四种线程池及new Thread的弊端

2024-04-28 00:48

本文主要是介绍详谈Java四种线程池及new Thread的弊端,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

详谈Java四种线程池及new Thread的弊端



new Thread 的弊端

执行异步任务只是如下 new Thread() 吗?

new Thread(new Runnable() {

    @Override

    public void run() {

        // TODO Auto-generated method stub

    }

}).start();


那你就太out了,new Thread的弊端如下:

1)每次通过new Thread()创建对象性能不佳。


2)线程缺乏统一管理,可能无限制新建线程,相互之间竞争,及可能占用过多系统资源导致死机或oom。


3)缺乏更多功能,如定时执行、定期执行、线程中断。


相比new ThreadJava提供的四种线程池的好处在于: 

1)重用存在的线程,减少对象创建、消亡的开销,提升性能。


2)可有效控制最大并发线程数,提高系统资源的使用率,同时避免过多资源竞争,避免堵塞。


3)提供定时执行、定期执行、单线程、并发数控制等功能。


Java 线程池

Java通过Executors提供四种线程池,分别为: 

newCachedThreadPool创建一个可缓存线程池,如果线程池长度超过处理需要,可灵活回收空闲线程,若无可回收,则新建线程。 


newFixedThreadPool 创建一个定长线程池,可控制线程最大并发数,超出的线程会在队列中等待。 


newScheduledThreadPool 创建一个定长线程池,支持定时及周期性任务执行。 


newSingleThreadExecutor 创建一个单线程化的线程池,它只会用唯一的工作线程来执行任务,保证所有任务按照指定顺序(FIFO, LIFO, 优先级)执行。


Java里面线程池的顶级接口是Executor,但是严格意义上讲Executor并不是一个线程池,而只是一个执行线程的工具。真正的线程池接口是ExecutorService。下面这张图完整描述了线程池的类体系结构:



1. newCachedThreadPool

创建一个可根据需要创建新线程的线程池,但是在以前构造的线程可用时将重用它们。对于执行很多短期异步任务的程序而言,这些线程池通常可提高程序性能。调用 execute 将重用以前构造的线程(如果线程可用)。


如果现有线程没有可用的,则创建一个新线程并添加到池中。终止并从缓存中移除那些已有 60 秒钟未被使用的线程。因此,长时间保持空闲的线程池不会使用任何资源。

public static ExecutorService newCachedThreadPool()


示例代码:

public class ThreadPoolExecutorTest {

   public static void main(String[] args ) {

    ExecutorService cacheThreadPool =Executors.newCachedThreadPool();

     for(int i =1;i<=5;i++){

       final int index=i ;

       try{

        Thread.sleep(1000);

      }catch(InterruptedException e ) {

         e.printStackTrace();

      }

       cacheThreadPool.execute(new Runnable(){

         @Override

         public void run() {

          System.out.println("第" +index +"个线程" +Thread.currentThread().getName());  

        }  

      });

    }

  }

}


//输出结果

第1个线程pool-1-thread-1

第2个线程pool-1-thread-1

第3个线程pool-1-thread-1

第4个线程pool-1-thread-1 第5个线程pool-1-thread-1  

由结果可看出 当执行第二个任务时第一个任务已经完成,会复用执行第一个任务的线程,而不用每次新建线程。


2. newFixedThreadPool

创建一个指定工作线程数量的线程池。每当提交一个任务就创建一个工作线程,如果工作线程数量达到线程池初始的最大数,则将提交的任务存入到池队列中。

public static ExecutorService newFixedThreadPool(int nThreads)


nThreads - 池中的线程数

示例代码:

public class ThreadPoolExecutorTest {

   public static void main(String[] args) {

    ExecutorService fixedThreadPool =Executors. newFixedThreadPool(3);

     for (int i =1; i<=5;i++){

       final int index=i ;

       fixedThreadPool.execute(new Runnable(){

         @Override

         public void run() {

           try {

            System.out.println("第" +index + "个线程" +Thread.currentThread().getName());

            Thread.sleep(1000);

          } catch(InterruptedException e ) {

             e .printStackTrace();

          }

        }

 

      });

    }

  }

}

由于设置最大线程数为3,所以在输出三个数后等待2秒后才继续输出。


2. newScheduledThreadPool

创建一个线程池,它可安排在给定延迟后运行命令或者定期地执行。

public static ScheduledExecutorService newScheduledThreadPool(int corePoolSize)


corePoolSize - 池中所保存的线程数,即使线程是空闲的也包括在内。


延迟执行示例代码:

public class ThreadPoolExecutorTest {  

  public static void main(String[] args) {

    ScheduledExecutorService scheduledThreadPool= Executors.newScheduledThreadPool(3);   

    scheduledThreadPool.schedule(newRunnable(){     

      @Override

      public void run() {

       System.out.println("延迟三秒");

       }

   }, 3, TimeUnit.SECONDS);

  }

}

表示延迟3秒执行。


定期执行示例代码:

public class ThreadPoolExecutorTest {  

  public static void main(String[] args) {

 

    ScheduledExecutorService scheduledThreadPool= Executors.newScheduledThreadPool(3);    

  scheduledThreadPool.scheduleAtFixedRate(newRunnable(){    

    @Override      

    public void run() {

       System.out.println("延迟1秒后每三秒执行一次");

     }

   },1,3,TimeUnit.SECONDS);

 }

 

}

表示延迟1秒后每3秒执行一次。


4.newSingleThreadExecutor

创建一个使用单个 worker 线程的 Executor,以无界队列方式来运行该线程。(注意,如果因为在关闭前的执行期间出现失败而终止了此单个线程,那么如果需要,一个新线程将代替它执行后续的任务)。可保证顺序地执行各个任务,并且在任意给定的时间不会有多个线程是活动的。与其他等效的 newFixedThreadPool(1)不同,可保证无需重新配置此方法所返回的执行程序即可使用其他的线程。


public static ExecutorService newSingleThreadExecutor()


示例代码:

public class ThreadPoolExecutorTest {  

  public static void main(String[] args) {

    ExecutorService singleThreadPool= Executors.newSingleThreadExecutor();    

    for(int i=1;i<=5;i++){      

      int index=i;      

    singleThreadPool.execute(new Runnable(){

       @Override

       public void run() {         

        try{

         System.out.println("第"+index+"个线程");

        Thread.sleep(2000);

         }catch(InterruptedException e) {            

          e.printStackTrace();

        }

      } });

    }

  }

}

这篇关于详谈Java四种线程池及new Thread的弊端的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/941938

相关文章

JVM 的类初始化机制

前言 当你在 Java 程序中new对象时,有没有考虑过 JVM 是如何把静态的字节码(byte code)转化为运行时对象的呢,这个问题看似简单,但清楚的同学相信也不会太多,这篇文章首先介绍 JVM 类初始化的机制,然后给出几个易出错的实例来分析,帮助大家更好理解这个知识点。 JVM 将字节码转化为运行时对象分为三个阶段,分别是:loading 、Linking、initialization

Spring Security 基于表达式的权限控制

前言 spring security 3.0已经可以使用spring el表达式来控制授权,允许在表达式中使用复杂的布尔逻辑来控制访问的权限。 常见的表达式 Spring Security可用表达式对象的基类是SecurityExpressionRoot。 表达式描述hasRole([role])用户拥有制定的角色时返回true (Spring security默认会带有ROLE_前缀),去

浅析Spring Security认证过程

类图 为了方便理解Spring Security认证流程,特意画了如下的类图,包含相关的核心认证类 概述 核心验证器 AuthenticationManager 该对象提供了认证方法的入口,接收一个Authentiaton对象作为参数; public interface AuthenticationManager {Authentication authenticate(Authenti

Spring Security--Architecture Overview

1 核心组件 这一节主要介绍一些在Spring Security中常见且核心的Java类,它们之间的依赖,构建起了整个框架。想要理解整个架构,最起码得对这些类眼熟。 1.1 SecurityContextHolder SecurityContextHolder用于存储安全上下文(security context)的信息。当前操作的用户是谁,该用户是否已经被认证,他拥有哪些角色权限…这些都被保

Spring Security基于数据库验证流程详解

Spring Security 校验流程图 相关解释说明(认真看哦) AbstractAuthenticationProcessingFilter 抽象类 /*** 调用 #requiresAuthentication(HttpServletRequest, HttpServletResponse) 决定是否需要进行验证操作。* 如果需要验证,则会调用 #attemptAuthentica

Spring Security 从入门到进阶系列教程

Spring Security 入门系列 《保护 Web 应用的安全》 《Spring-Security-入门(一):登录与退出》 《Spring-Security-入门(二):基于数据库验证》 《Spring-Security-入门(三):密码加密》 《Spring-Security-入门(四):自定义-Filter》 《Spring-Security-入门(五):在 Sprin

Java架构师知识体认识

源码分析 常用设计模式 Proxy代理模式Factory工厂模式Singleton单例模式Delegate委派模式Strategy策略模式Prototype原型模式Template模板模式 Spring5 beans 接口实例化代理Bean操作 Context Ioc容器设计原理及高级特性Aop设计原理Factorybean与Beanfactory Transaction 声明式事物

Java进阶13讲__第12讲_1/2

多线程、线程池 1.  线程概念 1.1  什么是线程 1.2  线程的好处 2.   创建线程的三种方式 注意事项 2.1  继承Thread类 2.1.1 认识  2.1.2  编码实现  package cn.hdc.oop10.Thread;import org.slf4j.Logger;import org.slf4j.LoggerFactory

JAVA智听未来一站式有声阅读平台听书系统小程序源码

智听未来,一站式有声阅读平台听书系统 🌟&nbsp;开篇:遇见未来,从“智听”开始 在这个快节奏的时代,你是否渴望在忙碌的间隙,找到一片属于自己的宁静角落?是否梦想着能随时随地,沉浸在知识的海洋,或是故事的奇幻世界里?今天,就让我带你一起探索“智听未来”——这一站式有声阅读平台听书系统,它正悄悄改变着我们的阅读方式,让未来触手可及! 📚&nbsp;第一站:海量资源,应有尽有 走进“智听

在cscode中通过maven创建java项目

在cscode中创建java项目 可以通过博客完成maven的导入 建立maven项目 使用快捷键 Ctrl + Shift + P 建立一个 Maven 项目 1 Ctrl + Shift + P 打开输入框2 输入 "> java create"3 选择 maven4 选择 No Archetype5 输入 域名6 输入项目名称7 建立一个文件目录存放项目,文件名一般为项目名8 确定