码迷,mamicode.com
首页 > 编程语言 > 详细

线程池的使用

时间:2020-07-09 22:22:40      阅读:60      评论:0      收藏:0      [点我收藏+]

标签:异常   ice   多线程   rdo   live   The   除了   lex   方式   

线程池

1.介绍

多线程缺点:

  • 处理任务的线程创建和销毁都非常的耗时间并消耗资源
  • 多线程之间的切换也会非常耗时并消耗资源

采用线程池的好处

  • 使用时线程已经存在,消除了线程创建的消耗
  • 通过设置线程数目,防止资源不足

2.ThreadPoolExecutor构造函数参数

public ThreadPoolExecutor(int corePoolSize,
                          int maximumPoolSize,
                          long keepAliveTime,
                          TimeUnit unit,
                          BlockingQueue<Runnable> workQueue,
                          ThreadFactory threadFactory,
                          RejectedExecutionHandler handler) {
  • corePoolSize:线程池中核心线程数的最大值,核心线程不会被销毁

  • maximumPoolSize:线程池中能拥有的最大线程数

    • 当线程池中最大线程数大于最大核心线程数时,剩下的非核心线程可以被销毁
  • workQueue:用于缓存任务的阻塞队列

    • SynchronousQueue:内部只能包含一个元素,当线程池没有空闲的线程,插入元素到队列的线程会被阻塞,知道有空闲的线程向队列请求任务,入列操作才可以继续进行,然后空闲线程就可以得到元素
    • LinkedBockingQueue:链表实现的队列,可以是有界也可以是无界
  • 阻塞队列是指当核心线程无空闲时,有新的任务进来,就会先添加到阻塞队列等待核心线程空闲

  • 上述三者关系:新的任务进来,如果没有空闲线程

    • 正在运行的线程数<corePoolSize,则添加新的线程执行
    • 正在运行的线程数=corePoolSize,阻塞队列未满,添加到阻塞队列
    • 正在运行的线程数<maximumPoolSize,阻塞队列已经满了,创建新的线程执行
    • 正在运行的线程数<maximumPoolSize,阻塞队列已经满了,根据构造函数中的handler指定的策略来拒绝新的任务
  • keepAliveTime:表示空闲的线程存活的时间

  • unit:keepAliveTime的单位

  • handler:拒绝新任务采取的策略

    ThreadPoolExecutor.ThreadAbortPolicy() 抛出RejectedExecutionException
    ThreadPoolExecutor.CallerRunsPolicy() 由向线程池提交任务的线程来执行任务
    ThreadPoolExecutor.DiscardOldestPolicy() 抛弃最旧的任务(最先提交而没有得到执行的任务)
    ThreadPoolExecutor.DiscardPolicy() 抛弃当前的任务
  • threadFactory:指定线程创建工厂

3.四种常见的线程池

介绍创建线程的时候我们提到过,javaSE定义了一个Executors类简化我们创建线程池的过程,提供了四个线程池的创建方法

1.newCachedThreadPool

  • 可缓存线程池,线程池长度超过处理需要,可以灵活回收空余线程,若无可回收,则新建线程

  • 特点:

    • 工作线程的创建几乎没有限制(隐形限制为Integer.Max_value)
    • 空闲的工作线程可以会销毁,有新任务重新创建
    • 使用时要注意控制任务的数量,大量线程同时运行有可能造成系统瘫痪
  • 使用

    //创建线程池
    ExecutorService cachedThreadPool = Executors.newCacheThreadPool();
    //启动线程,cachedThreadPool线程只能通过实现Runnable接口的方式实现
    cachedThreadPool.execute(new Runnable(){
        public void run(){
           	………… 
        }
    });
    

2.newFixedThreadPool

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

  • 优点:具有线程池提高程序效率和节省创建线程时所耗的开销

  • 缺点:线程池中的空闲线程不会自动销毁,线程池中没有可运行任务时,它不会释放工作线程,还有占用一定的系统资源,适合一直频繁有任务进行且任务量稳定的场景

  • 使用

    //3为自定义的线程数
    ExecutorService fixThreadPool = Executors.newFixedThreadPool(3);
    //使用方式和缓存线程池类似
    fixThreadPool.execute(new Runnable(){
        public void run(){
           	………… 
        }
    });
    

3.newSingleThreadExecutor

  • 创建一个单线程化的Executor,即只创建唯一的工作者线程来执行任务,他只会用唯一的工作线程来执行任务,保证所有任务按照指定顺序(FIFO,LIFO,优先级)执行。如果这个线程异常结束,会有另一个取代他,保证顺序执行
  • 单工作线程的最大特点是可保证顺序的执行各个任务,并且在任意给定的时间不会有多个线程是活动的。
  • 使用方式类似

4.newScheduleThreadPool

  • 定时线程:该方法创建一个定长的线程池,而且支持定时的以及周期性的任务执行

  • 使用

    //创建定长线程池
    ScheduleExecutorService scheduleThreadPool = Executors.scheduleThreadPool(5);
    //设置启动线程
    scheduleThreadPool.schedule(new Runnable(){
    	public void run(){
    		…………
    	}	
    },3,TimeUnit.SECONDS);
    //两个参数设置延迟时间,数值和单位,这里是3秒
    

线程池的使用

标签:异常   ice   多线程   rdo   live   The   除了   lex   方式   

原文地址:https://www.cnblogs.com/JIATCODE/p/13276283.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!