java线程池和线程实例化_浅谈Java 线程池原理及使用方式

一、简介

什么是线程池？

池的概念大家也许都有所听闻，池就是相当于一个容器，里面有许许多多的东西你可以即拿即用。java中有线程池、连接池等等。线程池就是在系统启动或者实例化池时创建一些空闲的线程，等待工作调度，执行完任务后，线程并不会立即被销毁，而是重新处于空闲状态，等待下一次调度。

线程池的工作机制？

在线程池的编程模式中，任务提交并不是直接提交给线程，而是提交给池。线程池在拿到任务之后，就会寻找有没有空闲的线程，有则分配给空闲线程执行，暂时没有则会进入等待队列，继续等待空闲线程。如果超出最大接受的工作数量，则会触发线程池的拒绝策略。

为什么使用线程池？

线程的创建与销毁需要消耗大量资源，重复的创建与销毁明显不必要。而且池的好处就是响应快，需要的时候自取，就不会存在等待创建的时间。线程池可以很好地管理系统内部的线程，如数量以及调度。

二、常用线程池介绍

Java类ExecutorService是线程池的父接口，并非顶层接口。以下四种常用线程池的类型都可以是ExecutorService。

单一线程池 Executors.newSingleThreadExecutor()

内部只有唯一一个线程进行工作调度，可以保证任务的执行顺序(FIFO,LIFO)

package com.test;

import java.util.ArrayList;

import java.util.List;

import java.util.concurrent.ExecutorService;

import java.util.concurrent.Executors;

public class PoolTest {

public static void main(String[] args) {

// 创建单一线程池

ExecutorService singleThreadExecutor = Executors.newSingleThreadExecutor();

List list = new ArrayList();

list.add("first");

list.add("second");

list.add("third");

list.forEach(o -> {

// 遍历集合提交任务

singleThreadExecutor.execute(new Runnable() {

@Override

public void run() {

System.out.println(Thread.currentThread().getName() + " : " + o);

try {

// 间隔1s

Thread.sleep(1000);

} catch (InterruptedException e) {

e.printStackTrace();

}

}

});

});

}

}

执行结果：

pool-1-thread-1 : first

pool-1-thread-1 : second

pool-1-thread-1 : third

可缓存线程池 Executors.newCachedThreadPool()

如果线程池中有可使用的线程，则使用，如果没有，则在池中新建一个线程，可缓存线程池中线程数量最大为Integer.MAX_VALUE。通常用它来运行一些执行时间短，且经常用到的任务。

package com.test;

import java.util.ArrayList;

import java.util.List;

import java.util.concurrent.ExecutorService;

import java.util.concurrent.Executors;

public class PoolTest {

public static void main(String[] args) {

// 创建可缓存线程池

ExecutorService cachedThreadPool = Executors.newCachedThreadPool();

List list = new ArrayList();

list.add("first");

list.add("second");

list.add("third");

list.forEach(o -> {

try {

// 间隔3s

Thread.sleep(3000);

} catch (InterruptedException e) {

e.printStackTrace();

}

// 遍历集合提交任务

cachedThreadPool.execute(new Runnable() {

@Override

public void run() {

System.out.println(Thread.currentThread().getName() + " : " + o);

try {

// 间隔1s

Thread.sleep(1000);

} catch (InterruptedException e) {

e.printStackTrace();

}

}

});

});

}

}

执行结果：

pool-1-thread-1 : first

pool-1-thread-1 : second

pool-1-thread-1 : third

因为间隔时间长，下一个任务运行时，上一个任务已经完成，所以线程可以继续复用，如果间隔时间调短，那么部分线程将会使用新线程来运行。

把每个任务等待时间从3s调低至1s:

执行结果：

pool-1-thread-1 : first

pool-1-thread-2 : second

pool-1-thread-1 : third

定长线程池 Executors.newFixedThreadPool(int nThreads)

创建一个固定线程数量的线程池，参数手动传入

package com.test;

import java.util.ArrayList;

import java.util.List;

import java.util.concurrent.ExecutorService;

import java.util.concurrent.Executors;

public class PoolTest {

public static void main(String[] args) {

// 创建可缓存线程池

ExecutorService fixedThreadPool = Executors.newFixedThreadPool(3);

List list = new ArrayList();

list.add("first");

list.add("second");

list.add("third");

list.add("fourth");

list.forEach(o -> {

try {

// 间隔1s

Thread.sleep(1000);

} catch (InterruptedException e) {

e.printStackTrace();

}

// 遍历集合提交任务

fixedThreadPool.execute(new Runnable() {

@Override

public void run() {

System.out.println(Thread.currentThread().getName() + " : " + o);

try {

// 间隔1s

Thread.sleep(1000);

} catch (InterruptedException e) {

e.printStackTrace();

}

}

});

});

}

}

执行结果：

pool-1-thread-1 : first

pool-1-thread-2 : second

pool-1-thread-3 : third

pool-1-thread-1 : fourth

定时线程池 Executors.newScheduledThreadPool(int corePoolSize)

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

package com.test;

import java.util.concurrent.Executors;

import java.util.concurrent.ScheduledExecutorService;

import java.util.concurrent.TimeUnit;

public class PoolTest {

public static void main(String[] args) {

// 创建定长线程池、支持定时、延迟、周期性执行任务

ScheduledExecutorService scheduledThreadPool = Executors.newScheduledThreadPool(3);

scheduledThreadPool.scheduleAtFixedRate(new Runnable() {

@Override

public void run() {

System.out.println(Thread.currentThread().getName() + " : 1秒后每隔3秒执行一次");

}

}, 1, 3, TimeUnit.SECONDS);

}

}

执行结果：

pool-1-thread-1 : 1秒后每隔3秒执行一次

pool-1-thread-1 : 1秒后每隔3秒执行一次

pool-1-thread-2 : 1秒后每隔3秒执行一次

pool-1-thread-2 : 1秒后每隔3秒执行一次

pool-1-thread-2 : 1秒后每隔3秒执行一次

pool-1-thread-2 : 1秒后每隔3秒执行一次

pool-1-thread-2 : 1秒后每隔3秒执行一次

三、自定义线程池

常用构造函数：

ThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, BlockingQueue workQueue)

参数说明：

1、corePoolSize 核心线程数大小，当线程数

2、maximumPoolSize 最大线程数， 当线程数 >= corePoolSize的时候，会把runnable放入workQueue中

3、keepAliveTime  保持存活时间，当线程数大于corePoolSize的空闲线程能保持的最大时间。

4、unit 时间单位

5、workQueue 保存任务的阻塞队列

6、threadFactory 创建线程的工厂

7、handler 拒绝策略

任务执行顺序：

1、当线程数小于corePoolSize时，创建线程执行任务。

2、当线程数大于等于corePoolSize并且workQueue没有满时，放入workQueue中

3、线程数大于等于corePoolSize并且当workQueue满时，新任务新建线程运行，线程总数要小于maximumPoolSize

4、当线程总数等于maximumPoolSize并且workQueue满了的时候执行handler的rejectedExecution。也就是拒绝策略。

ThreadPoolExecutor默认有四个拒绝策略：

1、new ThreadPoolExecutor.AbortPolicy()   直接抛出异常RejectedExecutionException

2、new ThreadPoolExecutor.CallerRunsPolicy()    直接调用run方法并且阻塞执行

3、new ThreadPoolExecutor.DiscardPolicy()   直接丢弃后来的任务

4、new ThreadPoolExecutor.DiscardOldestPolicy()  丢弃在队列中队首的任务

缓冲队列BlockingQueue：

BlockingQueue是双缓冲队列。BlockingQueue内部使用两条队列，允许两个线程同时向队列一个存储，一个取出操作。在保证并发安全的同时，提高了队列的存取效率。

常用的几种BlockingQueue：

ArrayBlockingQueue(int i):规定大小的BlockingQueue，其构造必须指定大小。其所含的对象是FIFO顺序排序的。

LinkedBlockingQueue()或者(int i):大小不固定的BlockingQueue，若其构造时指定大小，生成的BlockingQueue有大小限制，不指定大小，其大小有Integer.MAX_VALUE来决定。其所含的对象是FIFO顺序排序的。

PriorityBlockingQueue()或者(int i):类似于LinkedBlockingQueue，但是其所含对象的排序不是FIFO，而是依据对象的自然顺序或者构造函数的Comparator决定。

SynchronizedQueue():特殊的BlockingQueue，对其的操作必须是放和取交替完成。

package com.test;

import java.util.concurrent.LinkedBlockingDeque;

import java.util.concurrent.RejectedExecutionHandler;

import java.util.concurrent.ThreadPoolExecutor;

import java.util.concurrent.TimeUnit;

public class PoolTest {

public static void main(String[] args) {

// 工作队列

LinkedBlockingDeque workQueue = new LinkedBlockingDeque();

// 拒绝策略

RejectedExecutionHandler handler = new ThreadPoolExecutor.AbortPolicy();

ThreadPoolExecutor threadPoolExecutor = new ThreadPoolExecutor(2, 10, 20, TimeUnit.MILLISECONDS, workQueue, handler);

threadPoolExecutor.execute(new Runnable() {

@Override

public void run() {

System.out.println("自定义线程池");

}

});

}

}

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/news/271167.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

线性代数及其应用_线性代数入门——行列式的简单应用选讲

线性代数及其应用_线性代数入门——行列式的简单应用选讲

系列简介：这个系列文章讲解线性代数的基础内容，注重学习方法的培养。线性代数课程的一个重要特点(也是难点)是概念众多，而且各概念间有着千丝万缕的联系，对于初学者不易理解的问题我们会不惜笔墨加以解释。在内容上，以…
阅读更多...
引导类加载器 Bootstrap ClassLoader

引导类加载器 Bootstrap ClassLoader

阅读更多...
RocketMQ 使用及常见问题

RocketMQ 使用及常见问题

前言 本文档是针对RocketMQ使用及常见问题的说明。 一．获取项目、安装包及文档 1. alibaba/RocketMQ https://github.com/alibaba/RocketMQ 2. Download the latest release package https://github.com/alibaba/RocketMQ/releases 3.…
阅读更多...
系统开发基础：UML相关知识笔记

系统开发基础：UML相关知识笔记

1、UML概念统一建模语言（Unified Modeling Language UML）是面向对象软件的标准建模语言。由于简单、统一，又能够表达软件设计中的动态和静态信息。目前UML已经成为可视化建模语言的工业标准。2、UML的组成UML三要素：构造块、规则、…
阅读更多...
java中什么是运行异常_在java中最常用的运行时异常是什么？

java中什么是运行异常_在java中最常用的运行时异常是什么？

我从不会抛出NullPointerException。对我来说，它是一个出现在代码中当出现问题时，需要开发人员看看会发生什么。然后(s)他固定的原因，它不会再次发生。我使用IllegalStateException表示对象配置不正确或调用的顺序不正确。但是，我…
阅读更多...
迭代器 java_面试必备（含答案）：30 个 Java 高频面试问题

迭代器 java_面试必备（含答案）：30 个 Java 高频面试问题

Java集合框架为Java编程语言的基础，也是Java面试中很重要的一个知识点。这里，我列出了一些关于Java集合的重要问题和答案。1.Java集合框架是什么？说出一些集合框架的优点？每种编程语言中都有集合，最初的Java版本包含几…
阅读更多...
硬件基础：台式电脑上的常用的几个接口！

硬件基础：台式电脑上的常用的几个接口！

今天给大家详细讲解台式电脑上的常用的几个接口！1、I/O接口部分下图所有的接口，也是我们机箱后面的接口，统称为：I/O接口。2、键鼠PS/2PS/2接口是I/O接口中比较常见的一种接口，用来连接键盘和鼠标，二者可以用…
阅读更多...
系统类加载器 AppClassLoader

系统类加载器 AppClassLoader

阅读更多...
CSS-DOM介绍

CSS-DOM介绍

三位一体的网页: 我们在浏览器里看到的网页其实是由以下三层信息构成的一个共同体: 1、结构层: 结构层是由HTML和XHTML之类的标记语言所构成的。所就是哪些出现在html标签里面的单词,对网页内容的语义含义作出了如下描述&#xff0c;例如&#xff0c;<p>This is a paragr…
阅读更多...
java 开发注意项_JAVA开发注意事项集锦

java 开发注意项_JAVA开发注意事项集锦

本篇博客用于持续记录开发过程中的常用的需要注意的事项&#xff0c;都是严重的生产问题大家总结出来的、记得持续更新喔。一&#xff0c;不要以时间戳作为唯一健时间戳精确到ms级别&#xff0c;并不能作为唯一入口参数&#xff0c;数据库更新唯一查询参数&#xff0c;唯一健需…
阅读更多...
系统开发基础：UML中图的相关知识笔记（上）

系统开发基础：UML中图的相关知识笔记（上）

1、图的概念图(Diagram) 是一组元素的图形表示&#xff0c;大多数情况下&#xff0c;把图画成顶点&#xff08;代表事物&#xff09;和弧(表示关系)的连通图。2、UML中图的分类UML2.0中的图主要有&#xff1a;类图、对象图、用例图、序列图、通信图、状态图、活动图、构件图、部…
阅读更多...
python循环顶帖_设计Python数据库连接池1-对象的循环引用问题

python循环顶帖_设计Python数据库连接池1-对象的循环引用问题

在Python中如果对象定义了__del__方法的话&#xff0c;在对象的引用记数为0时会自动调用__del__方法(很象c中的析构函数)&#xff0c;但如果A对象引用B对象&#xff0c;B对象又引用A对象&#xff0c;就形成循环引用&#xff0c;此时A&#xff0c;B对象引用次数都为1。python就无…
阅读更多...
扩展类加载器 Extension ClassLoader

扩展类加载器 Extension ClassLoader

阅读更多...
编译时类型 和运行时类型的 区别（1）

编译时类型 和运行时类型的 区别（1）

class T{ void f(int x){ System.out.println("int in T:" x); } void f(double x){ System.out.println("double in T:"x); } void f(Object x){ System.out.println("Object in T:" x); }} class S extends T{ void f(int x){　　//子类覆盖基…
阅读更多...
系统开发基础：UML中图的相关知识笔记（下）

系统开发基础：UML中图的相关知识笔记（下）

1、状态图状态图展现了一个状态机&#xff0c;它由状态、转换、事件、活动组成。状态图关注系统的动态视图&#xff0c;它对于接口、类、协作的行为建模尤为重要&#xff0c;它强调对象行为的事件顺序。组成&#xff1a;简单状态、组合状态、转换&#xff08;事件和动作&#x…
阅读更多...
java京东左侧固定层_京东首页右侧固定层

java京东左侧固定层_京东首页右侧固定层

需求说明制作京东首页右侧的固定层&#xff0c;6个图标&#xff1a;京东会员、购物车、我的关注、我的足迹、我的消息和咨询JIMI默认状态下仅显示图标&#xff0c;背景颜色为深灰色&#xff1b;当鼠标移至图标上时&#xff0c;背景颜色为深红色&#xff0c;并且显示文本css*{ma…
阅读更多...
云开发技术应用python_云开发技术应用（Python）

云开发技术应用python_云开发技术应用（Python）

本书共14章&#xff0c;从Python语言的语法特性开始&#xff0c;介绍了Python的安装和配置、数据类型及表达式、流程控制、序列和字典、文件处理、函数等&#xff0c;由浅入深&#xff0c;循序渐进&#xff0c;逐步引入高级话题&#xff0c;包括面向对象编程、模块和包、异常处…
阅读更多...
记录下Linux难记实用的命令

记录下Linux难记实用的命令

1 看文件大小&#xff1a;du -sm * | sort -n 2 合并多个文件&#xff0c;可以跨文件夹合并&#xff1a;cat *_.txt >> news.txt 3 给文件改编码&#xff1a;iconv -f GBK -t UTF-8 原文件名 -o 新文件名 4 查找文件内容&#xff1a;grep "thermcontact" */*.i…
阅读更多...
系统设计基础：系统设计基本任务相关知识

系统设计基础：系统设计基本任务相关知识

1、系统设计的目的提前为系统指定蓝图&#xff0c;在各种技术和实施方法中进行权衡&#xff0c;精心设计&#xff0c;合理利用各种资源、最终确定新系统的详细设计方案。2、系统设计的内容系统设计的内容主要包括系统总体结构设计、代码设计、输出设计、输入设计、处理过程设计…
阅读更多...
java7 3dm下载_3DM游戏运行库合集安装包v2.8

java7 3dm下载_3DM游戏运行库合集安装包v2.8

游戏运行库大全 游戏运行环境 所有游戏组件 32位 64位系统常用运行库合集 3DM游戏常用运行库安装包 下载 幸姨作品本安装包集成32位和64位运行库&#xff0c;是目前互联网上最新最全的常用运行库合集&#xff0c;能自动识别系统版本以提供适合您的组件&#xff0c;无人值守自动…
阅读更多...
最新文章

Copyright @ 2022~2023