java核心知识点 --- 线程池ThreadPool

线程池是多线程学习中需要重点掌握的.

系统启动一个新线程的成本是比较高的,因为它涉及与操作系统交互.在这种情形下,使用线程池可以很好的提高性能,尤其是当程序中需要创建大量生存期很短暂的线程时,更应该考虑使用线程池.

一.如何创建线程池??

在Java5之前,线程池都是开发才手动实现的,从Java5开始,Java内建支持线程池.主要是新增了一个executors工厂类来生产线程池.

1.newCachedThreadPool():创建一个具有缓存功能的线程池,系统根据需要创建线程,这些线程将会被缓存到线程池中.

2.newFixedThreadPool(int nThreads):创建一个可重用的,具有固定线程数的线程池.

3.newSingleThreadExecutor():创建一个只有单线程的线程池,它相当于调用newFixedThreadPool()方法传入参数为1;

4.newScheduledThreadPool(int corePoolSize)指池中所保存的线程数,即使线程是空闲的也被保存在线程池内;

5.newSingleThreadScheduledExecutor():创建只有一个线程的线程池,它可以在指定延迟后执行线程任务;

上面5个方法中的前3个方法返回一个ExecutorService对象,该对象代表一个线程池,它可以执行Runnable对象或Callable对象所代表的线程;而后2个方法返回一个ScheduledExecutorService线程池,它是ExecutorService的子类.

二.如何使用线程池?

举例:

package com.amos.concurrent;

import java.util.List;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.TimeUnit;

/**
* @ClassName: ThreadPoolTest
* @Description: java5中的线程池
* @author: amosli
* @email:[email protected]
* @date Apr 21, 2014 2:13:27 AM
*/
public class ThreadPoolTest {

    public static void main(String[] args) {
//        ExecutorService executorService = Executors.newFixedThreadPool(3);//设置固定的线程数
//        ExecutorService executorService = Executors.newCachedThreadPool();//创建带缓存的线程池,自动分配线程数
        ExecutorService executorService = Executors.newSingleThreadExecutor();//创建单一线程池,如何实现线程死了,马上自动重新建一个
        Executors.newScheduledThreadPool(3).schedule(new Runnable() {//创建一个有3个线程数的线程池,批定3秒后执行run方法里的内容
            public void run() {
                System.out.println("bomb.....");
            }
        }, 3, TimeUnit.SECONDS    );//隔3秒

        for (int i = 0; i < 10; i++) {//创建10个任务
            final int task = i;
            executorService.execute(new Runnable() {//执行任务的线程
                public void run() {
                    for (int i = 0; i < 10; i++) {//循环执行10个次
                        System.out.println(Thread.currentThread().getName() + "  loop" + i + " task is" + task);
                    }
                }
            });
        }
        System.out.println("all of 10 task has committed!!");
        List<Runnable> shutdownNow = executorService.shutdownNow();//立即关闭线程,并返回未执行的线程
        System.out.println("closed thread size:"+shutdownNow.size());
        for(Runnable a:shutdownNow){
            System.out.println(a);
        }
    }
}

运行效果:

创建一个单一的线程池,将任务加入了线程池,被关闭的线程有9个,在3秒后执行了输出‘bomb....‘

三.线程池使用注意事项

1.日常开发中Executors.newFixedThreadPool()是比较常用到的.

2.如何定时执行任务?

在执行指定时间执行任务时,比如要在中午12:00时运行一次,那么可以schedule(task, date.getTime() - 
 System.currentTimeMillis(), TimeUnit.MILLISECONDS).也即时采用倒计时的方式去执行定时操作,这个是Java官方文档建议使用的.

3.扩展---每隔2秒运行一次任务,持续一个小时

package com.amos.concurrent;

import static java.util.concurrent.TimeUnit.SECONDS;

import java.util.Date;
import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.ScheduledFuture;

class BeeperControl {
    private final ScheduledExecutorService scheduler = Executors.newScheduledThreadPool(1);

    public void beepForAnHour() {
        final Runnable beeper = new Runnable() {
            public void run() {
            System.out.println(new Date().getSeconds());//计时
            System.out.println("beep");
            }
        };
        final ScheduledFuture beeperHandle = scheduler.scheduleAtFixedRate(beeper, 10, 2, SECONDS);//任务,10s delay,2s/次,单位秒 

        scheduler.schedule(new Runnable() {
            public void run() {
                beeperHandle.cancel(true);//撤消任务
            }
        }, 60 * 60, SECONDS);//60*60s=60min=1h
    }
}
public class test{
    public static void main(String[] args) {
        System.out.println(new Date().getSeconds());//计时
        new BeeperControl().beepForAnHour();
    }
}

这个例子,是java官方提供的,这里稍做了修改,运行效果如下:

注:第一次运行是在0秒,10秒后开始第一次beep,然后每隔2秒beep一次;

这里首先是创建一个任务线程池: Executors.newScheduledThreadPool(1),设置了线程数为1,然后实现了一个runnable接口,再然后就是调用了scheduleAtFixedRate方法,指定频率,指定延时,执行beep任务,最后又实现了一个runnable接口,延时1小时执行撤消线程的任务.

原文地址:https://www.cnblogs.com/ncy1/p/9164458.html

时间: 2024-10-11 22:55:11

java核心知识点 --- 线程池ThreadPool的相关文章

Java核心知识点学习----多线程 倒计时记数器CountDownLatch和数据交换的Exchanger

本文将要介绍的内容都是Java5中的新特性,一个是倒计时记数器---CountDownLatch,另一个是用于线程间数据交换的Exchanger. 一.CountDownLatch 1.什么是CountDownLatch? 倒计时计数器,调用CountDownLatch对象的CountDown()方法就将计数器减一,当计数到达0时,则所有等待者或者全部等待者开始执行. 2.如何用? new CountDownLatch(1); 直接new,其构造函数必须传一个int类型的参数,参数的意思是: c

完全解析线程池ThreadPool原理&amp;使用

目录 1. 简介 2. 工作原理 2.1 核心参数 线程池中有6个核心参数,具体如下 上述6个参数的配置 决定了 线程池的功能,具体设置时机 = 创建 线程池类对象时 传入 ThreadPoolExecutor类 = 线程池的真正实现类 开发者可根据不同需求 配置核心参数,从而实现自定义线程池 // 创建线程池对象如下 // 通过 构造方法 配置核心参数 Executor executor = new ThreadPoolExecutor( CORE_POOL_SIZE, MAXIMUM_POO

JAVA多线程(三) 线程池和锁的深度化

github演示代码地址:https://github.com/showkawa/springBoot_2017/tree/master/spb-demo/src/main/java/com/kawa/thread 1.线程池 1.1 线程池是什么 Java中的线程池是运用场景最多的并发框架,几乎所有需要异步或并发执行任务的程序都可以使用线程池.在开发过程中,合理地使用线程池能够带来3个好处. 第一:降低资源消耗.通过重复利用已创建的线程降低线程创建和销毁造成的消耗. 第二:提高响应速度.当任务

Java中的线程池

综述 在我们的开发中经常会使用到多线程.例如在Android中,由于主线程的诸多限制,像网络请求等一些耗时的操作我们必须在子线程中运行.我们往往会通过new Thread来开启一个子线程,待子线程操作完成以后通过Handler切换到主线程中运行.这么以来我们无法管理我们所创建的子线程,并且无限制的创建子线程,它们相互之间竞争,很有可能由于占用过多资源而导致死机或者OOM.所以在Java中为我们提供了线程池来管理我们所创建的线程. 线程池的使用 采用线程池的好处 在这里我们首先来说一下采用线程池的

Java核心知识点学习----多线程中的阻塞队列,ArrayBlockingQueue介绍

1.什么是阻塞队列? 所谓队列,遵循的是先进先出原则(FIFO),阻塞队列,即是数据共享时,A在写数据时,B想读同一数据,那么就将发生阻塞了. 看一下线程的四种状态,首先是新创建一个线程,然后,通过start方法启动线程--->线程变为可运行可执行状态,然后通过数据产生共享,线程产生互斥---->线程状态变为阻塞状态---->阻塞状态想打开的话可以调用notify方法. 这里Java5中提供了封装好的类,可以直接调用然后构造阻塞状态,以保证数据的原子性. 2.如何实现? 主要是实现Blo

高效线程池(threadpool)的实现

高效线程池(threadpool)的实现 Nodejs编程是全异步的,这就意味着我们不必每次都阻塞等待该次操作的结果,而事件完成(就绪)时会主动回调通知我们.在网络编程中,一般都是基于Reactor线程模型的变种,无论其怎么演化,其核心组件都包含了Reactor实例(提供事件注册.注销.通知功能).多路复用器(由操作系统提供,比如kqueue.select.epoll等).事件处理器(负责事件的处理)以及事件源(linux中这就是描述符)这四个组件.一般,会单独启动一个线程运行Reactor实例

多线程系列(2)线程池ThreadPool

上一篇文章我们总结了多线程最基础的知识点Thread,我们知道了如何开启一个新的异步线程去做一些事情.可是当我们要开启很多线程的时候,如果仍然使用Thread我们需要去管理每一个线程的启动,挂起和终止,显然是很麻烦的一件事情.还好.net framework为我们提供了线程池ThreadPool来帮助我们来管理这些线程,这样我们就不再需要手动地去终止这些线程.这一篇文章就让我们来学习一下线程池ThreadPool吧.关于它我想从以下几个方面进行总结. 认识线程池ThreadPool Thread

Java实现的 线程池

由于最近开始学习java,用到了线程池,按照之前c++的写法写出此java版的线程池 TaskRunnale实现相关任务的接口,具体要实现什么任务在相应的run函数中实现. package threadpool; import java.util.ArrayDeque; import java.util.ArrayList; import java.util.List; import java.util.Queue; class TaskRunnale implements Runnable {

Java多线程和线程池(转)

1.为什么要使用线程池 在java中,如果每个请求到达就创建一个新线程,开销是相当大的.在实际使用中,服务器在创建和销毁线程上花费的时间和消耗的系统资源都相当大,甚至可能要比在处理实际的用户请求的时间和资源要多的多.除了创建和销毁线程的开销之外,活动的线程也需要消耗系统资源.如果在一个jvm里创建太多的线程,可能会使系统由于过度消耗内存或“切换过度”而导致系统资源不足.为了防止资源不足,服务器应用程序需要采取一些办法来限制任何给定时刻处理的请求数目,尽可能减少创建和销毁线程的次数,特别是一些资源