java 是一种可以撰写跨平台应用软件的面向对象的程序设计语言,是由 Sun Microsystems 公司于 1995 年 5 月推出的 Java 程序设计语言和 Java 平台(即 JavaEE(j2ee), JavaME(j2me), JavaSE(j2se))的总称。
系统启动一个新线程的成本是比较高的,因为它涉及到与操作系统的交互。在这种情况下,使用线程池可以很好的提供性能,尤其是当程序中需要创建大量生存期很短暂的线程时,更应该考虑使用线程池
线程池系统启动一个新线程的成本是比较高的,因为它涉及到与操作系统的交互。在这种情况下,使用线程池可以很好的提供性能,尤其是当程序中需要创建大量生存期很短暂的线程时,更应该考虑使用线程池。
与数据库连接池类似的是,线程池在系统启动时即创建大量空闲的线程,程序将一个 Runnable 对象传给线程池,线程池就会启动一条线程来执行该对象的 run 方法,当 run 方法执行结束后,该线程并不会死亡,而是再次返回线程池中成为空闲状态,等待执行下一个 Runnable 对象的 run 方法。
除此之外,使用线程池可以有效地控制系统中并发线程的数量,但系统中包含大量并发线程时,会导致系统性能剧烈下降,甚至导致 JVM 崩溃。而线程池的最大线程数参数可以控制系统中并发的线程不超过此数目。
在 JDK1.5 之前,开发者必须手动的实现自己的线程池,从 JDK1.5 之后,Java 内建支持线程池。
与多线程并发的所有支持的类都在
包中。我们可以使用里面的类更加的控制多线程的执行。
- java.util.concurrent
系统启动一个新线程的成本是比较高的,因为它涉及到与操作系统的交互。在这种情况下,使用线程池可以很好的提供性能,尤其是当程序中需要创建大量生存期很短暂的线程时,更应该考虑使用线程池
JDK1.5 中提供 Executors 工厂类来产生连接池,该工厂类中包含如下的几个静态工程方法来创建连接池:
1、
:创建一个可重用的、具有固定线程数的线程池。
- public static ExecutorService newFixedThreadPool(int nThreads)
2、
:创建一个只有单线程的线程池,它相当于 newFixedThreadPool 方法是传入的参数为 1
- public static ExecutorService newSingleThreadExecutor()
3、
:创建一个具有缓存功能的线程池,系统根据需要创建线程,这些线程将会被缓存在线程池中。
- public static ExecutorService newCachedThreadPool()
4、
:创建只有一条线程的线程池,他可以在指定延迟后执行线程任务
- public static ScheduledExecutorService newSingleThreadScheduledExecutor
5、
:创建具有指定线程数的线程池,它可以再指定延迟后执行线程任务,corePoolSize 指池中所保存的线程数,即使线程是空闲的也被保存在线程池内。
- public static ScheduledExecutorService newScheduledThreadPool(int corePoolSize)
上面的几个方法都有一个重载的方法,多传入一个 ThreadFactory 参数的重载方法,使用的比较少。
二、ExecutorService 类可以看到上面的 5 个方法中,前面 3 个方法的返回值都是一个 ExecutorService 对象。该 ExecutorService 对象就代表着一个尽快执行线程的线程池(只要线程池中有空闲线程立即执行线程任务),程序只要将一个 Runnable 对象或 Callable 对象提交给该线程池即可,该线程就会尽快的执行该任务。
ExecutorService 有几个重要的方法:更详细的参考 JDK API 文档。
submit 方法是对 Executor 接口 execute 方法的更好的封装,建议使用 submit 方法。
三、ScheduleExecutorService 类在上面的 5 个方法中,后面 2 个方法的返回值都是一个 ScheduleExecutorService 对象。ScheduleExecutorService 代表可在指定延迟或周期性执行线程任务的线程池。
ScheduleExecutorService 类是 ExecutorService 类的子类。所以,它里面也有直接提交任务的 submit 方法,并且新增了一些延迟任务处理的方法:
下面看看线程池的简单使用:1、固定大小的线程池:
- package com.bjpowernode.test;
- import java.util.concurrent.ExecutorService;
- import java.util.concurrent.Executors;
- public class PoolTest {
- public static void main(String[] args) {
- ExecutorService pool=Executors.newFixedThreadPool(5);//创建一个固定大小为5的线程池
- for(int i=0;i<7;i++){
- pool.submit(new MyThread());
- }
- pool.shutdown();
- }
- }
- class MyThread extends Thread{
- @Override
- public void run() {
- System.out.println(Thread.currentThread().getName()+"正在执行。。。");
- }
- }
输出结果:
- pool-1-thread-1正在执行。。。
- pool-1-thread-3正在执行。。。
- pool-1-thread-2正在执行。。。
- pool-1-thread-4正在执行。。。
- pool-1-thread-4正在执行。。。
- pool-1-thread-5正在执行。。。
- pool-1-thread-1正在执行。。。
可以看到虽然我们呢创建了 7 个 MyThread 线程对象,但是由于受线程池的大小限制,只是开启了 5 个线程,这样就减少了并发线程的数量。
2、单任务线程池:
- public class PoolTest {
- public static void main(String[] args) {
- ExecutorService pool = Executors.newSingleThreadExecutor(); //创建一个单线程池
- for (int i = 0; i < 7; i++) {
- pool.submit(new MyThread());
- }
- pool.shutdown();
- }
- }
输出结果:
- pool-1-thread-1正在执行。。。
- pool-1-thread-1正在执行。。。
- pool-1-thread-1正在执行。。。
- pool-1-thread-1正在执行。。。
- pool-1-thread-1正在执行。。。
- pool-1-thread-1正在执行。。。
- pool-1-thread-1正在执行。。。
可以看到,线程池只开启了一个线程。
3、创建可变尺寸的线程池
- public class PoolTest {
- public static void main(String[] args) {
- ExecutorService pool = Executors.newCachedThreadPool();
- for (int i = 0; i < 5; i++) {
- pool.submit(new MyThread());
- }
- pool.shutdown();
- }
- }
看输出结果:
- pool-1-thread-1正在执行。。。
- pool-1-thread-3正在执行。。。
- pool-1-thread-2正在执行。。。
- pool-1-thread-4正在执行。。。
- pool-1-thread-5正在执行。。。
可以看到,我们没有限制线程池的大小,但是它会根据需求而创建线程。
4、延迟线程池
- public class PoolTest {
- public static void main(String[] args) {
- ScheduledExecutorService pool = Executors.newScheduledThreadPool(6);
- for (int i = 0; i < 4; i++) {
- pool.submit(new MyThread());
- }
- pool.schedule(new MyThread(), 1000, TimeUnit.MILLISECONDS);
- pool.schedule(new MyThread(), 1000, TimeUnit.MILLISECONDS);
- pool.shutdown();
- }
- }
输出结果:
- pool-1-thread-1正在执行。。。
- pool-1-thread-3正在执行。。。
- pool-1-thread-2正在执行。。。
- pool-1-thread-4正在执行。。。
- pool-1-thread-6正在执行。。。
- pool-1-thread-1正在执行。。。
可以明显看到,最后两个线程不是立即执行,而是延迟了 1 秒在执行的。
5、单任务延迟线程池
- public class PoolTest {
- public static void main(String[] args) {
- ScheduledExecutorService pool = Executors.newSingleThreadScheduledExecutor();
- for (int i = 0; i < 4; i++) {
- pool.submit(new MyThread());
- }
- pool.schedule(new MyThread(), 1000, TimeUnit.MILLISECONDS);
- pool.schedule(new MyThread(), 1000, TimeUnit.MILLISECONDS);
- pool.shutdown();
- }
- }
上面我们使用的是 JDK 帮我封装好的线程池,我们也可以自己定义线程池,查看源码,我们发现,Excutors 里面的获得线程的静态方法,内部都是调用 ThreadPoolExecutor 的构造方法。比如:
- public static ExecutorService newFixedThreadPool(int nThreads, ThreadFactory threadFactory) {
- return new ThreadPoolExecutor(nThreads, nThreads,
- 0L, TimeUnit.MILLISECONDS,
- new LinkedBlockingQueue<Runnable>(),
- threadFactory);
- }
可以看到,它是通过调用 ThreadPoolExecutor 的构造方法来返回一个线程池的。所以,我们也可以自己手动的调用 ThreadPoolExecutor 的各种构造方法,来定义自己的线程池规则,不过一般情况下,使用自带的线程池就够了,不需要自己来实现。
以上所述是小编给大家介绍的 Java 线程池,希望对大家有所帮助,如果大家有任何疑问请给我留言,小编会及时回复大家的。在此也非常感谢大家对 PHPERZ 网站的支持!
来源: http://www.phperz.com/article/17/1230/356817.html