首页 > 编程 > Java > 正文

java的线程池ExecutorService简单介绍

2019-11-06 06:58:47
字体:
来源:转载
供稿:网友

        做java的开发,线程是经常用的。最简单的使用大家都应该清楚,如继承Thread类、实现Runnable接口。这样,是没有问题。但是当我们需要频繁的处理一些任务时候,就要多次创建线程和处理线程关闭等回收工作。 这样比较麻烦。并且如果同时不限制线程个数,很多个任务一起执行,对性能有一定影响。所以,java提供了Executor线程池来处理并发任务,并且可以支持4种模式:

   1.newCachedThreadPool:    创建一个可缓存线程池,如果线程池长度超过处理需要,可灵活回收空闲线程,若无可回收,则新建线程。    2.newFixedThreadPool:创建一个定长线程池,可控制线程最大并发数,超出的线程会在队列中等待。    3.newScheduledThreadPool: 创建一个定长线程池,支持定时及周期性任务执行。    4.newSingleThreadExecutor: 创建一个单线程化的线程池,它只会用唯一的工作线程来执行任务,保证所有任务按照指定顺序(FIFO, LIFO, 优先级)执行。  

一 创建线程池 

// 创建可以容纳3个线程的线程池  ExecutorService fixedThreadPool = Executors.newFixedThreadPool(3);    // 线程池的大小会根据执行的任务数动态分配  ExecutorService cachedThreadPool = Executors.newCachedThreadPool();    // 创建单个线程的线程池,如果当前线程在执行任务时突然中断,则会创建一个新的线程替代它继续执行任务    ExecutorService singleThreadPool = Executors.newSin // 效果类似于Timer定时器 ScheduledExecutorService scheduledThreadPool = Executors.newScheduledThreadPool(3);

二 启动线程池

启动线程提供了2个方法:ExecutorService 的submit() 与execute(),定义如下:     

<T> Future<T> submit(Callable<T> var1);<T> Future<T> submit(Runnable var1, T var2);Future<?> submit(Runnable var1);void execute(Runnable var1);

三  关闭线程池

  使用以下的方法:   1.shutdown() 方法: 关闭线程池资源。不再接受新的任务,之前提交的任务等待执行结束再关闭。并且回收资源。    2.shutdownNow(): 立即关闭,通过调用Thread.interrupt来实现线程的立即退出。执行该方法,线程池的状态立刻变成STOP状态,并试图停止所有正在执行的线程,不再处理还在池队列中等待的任务。并且回收资源。  

四 new Thread和线程池创建线程区别

    new Thread的弊端如下:   a. 每次new Thread新建对象性能差。   b. 线程缺乏统一管理,可能无限制新建线程,相互之间竞争,及可能占用过多系统资源导致死机或oom。   c. 缺乏更多功能,如定时执行、定期执行、线程中断。  相比new Thread,Java提供的四种线程池的好处在于:  a. 重用存在的线程,减少对象创建、消亡的开销,性能佳。  b. 可有效控制最大并发线程数,提高系统资源的使用率,同时避免过多资源竞争,避免堵塞。  c. 提供定时执行、定期执行、单线程、并发数控制等功能。  


发表评论 共有条评论
用户名: 密码:
验证码: 匿名发表