自己有一个多线程并发的问题一直没能很好地解决,需求是:
对一批数据逐一的进行处理,而在单线程执行过程时效率太低,每5-10分钟才能处理一条数据,这期间大部分时间耗在了等待服务器响应请求上,于是乎想到了使用多线程并发处理,这样的话如果开30个线程,那么10分钟至少能处理30条数据,效率大大的提高。
在没有使用java 线程池的情况下我是这么做的
-------------------------------多线程并发实现---------------------------------
package threadPool;
public class Task extends Thread{
public int num = 0;//每个线程处理数据的个数
public void setNum(int num){
this.num = num;
}
public void process(){}
public void run(){
for(int i=0; i<num; i++ ){
process();
}
}
public static void main(String args[]){
int threadNum = 30;
int taskNum = 300;//需要处理任务的数量
for(int i =0; i<30; i++){
Task task = new Task();
task.setNum(taskNum/threadNum);
task.start();
}
}
}
这样实现会出现一个问题,就是在运行后期会出现某个线程已经把分配的任务处理完,而某些线程可能还有多个未处理完,而此时线程数量是小于最初设定好30个线程的。影响后面执行的效率。
当学习了java线程池后,豁然开朗,这个问题也迎刃而解:
先了解下java线程池的几个重要的类和接口:
1、ExecutorService:java线程池的接口,它实现了Executor接口。
2、ThreadPoolExecutor:ExecutorService接口的实现类。
3、Executors:获取线程的工厂类,其中定义了许多获取ThreadPoolExecutor对象的方法。
Executors工厂方法可获取的对象:
1、newSingleThreadExecutor:创建一个单线程的线程池。这个线程池只有一个线程在工作,也就是相当于单线程串行执行所有任务。如果这个唯一的线程因为异常结束,那么会有一个新的线程来替代它。此线程池保证所有任务的执行顺序按照任务的提交顺序执行。
2、newFixedThreadPool:创建固定大小的线程池。每次提交一个任务就创建一个线程,直到线程达到线程池的最大大小。线程池的大小一旦达到最大值就会保持不变,如果某个线程因为执行异常而结束,那么线程池会补充一个新线程。
3、newCachedThreadPool:创建一个可缓存的线程池。如果线程池的大小超过了处理任务所需要的线程,那么就会回收部分空闲(60秒不执行任务)的线程,当任务数增加时,此线程池又可以智能的添加新线程来处理任务。此线程池不会对线程池大小做限制,线程池大小完全依赖于操作系统(或者说JVM)能够创建的最大线程大小。
4、newScheduledThreadPool:创建一个大小无限的线程池。此线程池支持定时以及周期性执行任务的需求。
5、newSingleThreadExecutor:创建一个单线程的线程池。此线程池支持定时以及周期性执行任务的需求。
使用Executors.newFixedThreadPool(threadNum)方法可以实现对一批数据的多线程处理,同时可以合理的分配任务。假如处理300条数据,则当某一个线程处理完成后,即可自动的从未处理的数据里面拿出一条数据进行处理,无需对每一个线程进行任务分配。
----------------------------------下面是java线程池实现--------------------------
class TaskThreadPool extends Thread{
public void process(){}
public void run(){
process();
}
public static void main(String args[]){
int threadNum = 30;
ExecutorService pool = Executors.newFixedThreadPool(threadNum);
int taskNum = 300;//需要处理任务的数量
for(int i =0; i<300; i++){
Task task = new Task();
pool.execute(task);
}
}
}
相关推荐
Java分布式应用学习笔记07线程池应用
当然,现在用过的东西并不是代表以后还能娴熟的使用,做好笔记非常重要; 1:必须明白为什么要使用线程池:(这点很重要) a:手上项目所需,因为项目主要的目的是实现多线程的数据推送;需要创建多线程的话,那...
当调用 start 启动线程时 Java 虚拟机会调 用该类的 run方法。 那么该类的 run() 方法中就是调用了 Runnable 对象的 run() 方法。 我 们可以继承重写Thread 类,在其 start 方法中添加不断循环调用传递过来的 ...
Java 并发学习笔记: 进程和线程, 并发理论, 并发关键字, Lock 体系, 原子操作类, 发容器 & 并发工具, 线程池, 并发实践 Java是一种面向对象的编程语言,由Sun Microsystems于1995年推出。它是一种跨平台的...
学习笔记:整理了Java语言在游戏开发中的核心知识点和常用技术,方便你随时查阅和学习。 适用人群: 这份资源包适用于所有对Java游戏开发感兴趣的朋友,无论你是计算机专业的学生,还是希望业余时间尝试游戏开发的...
本篇文章主要介绍了java多线程学习笔记之自定义线程池 ,小编觉得挺不错的,现在分享给大家,也给大家做个参考。一起跟随小编过来看看吧
Java技术基础 4 1.1编程语言 4 1.2 Java的特点 4 1.3 Java开发环境 4 1.4 Java开发环境配置 5 1.5 Linux命令与相关知识 5 1.6 Eclipse/Myeclipse程序结构 6 Java语言基础 7 ...5.14线程池 67 5.15双缓冲队列 68
本文档主要内容如下: 1、线程安全和锁 Synchronized 底层实现原理...8、线程池原理和如何使用线程池 9、ThreadLocal 为什么会内存泄漏 10、Volatile底层实现原理 11、AQS源码分析 12、CAS原理分析和使用场景 13、.....
线程池框架2 第一层结构2 接口简介3 核心实现类3 辅助类4 完成服务4 源码原理解析4 线程池执行原理4 调度线程池原理7 异步结果源码分析10
花费了一上午的时候 写了一些demo。认识到四种线程池的区别。上传到csdn 供以后学习
Java-noteJava学习笔记java相关Java基础Java集合JVMJava并发线程池Java网络计算机基础数据库计算机网络操作系统面向对象思想面向对象设计模式Java WebSpringSpringBoot
线程安全、volatile关键字、原子性、并发包、死锁、线程池学习笔记
其中采用Java 的ExecutorService来进行线程池的方式实现多线程,模拟客户端多用户向同一服务器端发送请求....注意,此为学习笔记,可以作为参考学习使用,不建议商业使用或生产使用。 废话不多说,直接上代码。
Java并发编程 背景介绍 并发历史 必要性 进程 资源分配的最小单位 线程 CPU调度的最小单位 线程的优势 (1)如果设计正确,多线程程序可以通过提高处理器资源的利用率来提升系统吞吐率 ...
Java并发编程学习笔记 这是我两年前(2012-05)的学习笔记。。 -- 本文不会详细介绍java5以前的多线程开发的知识,而是重点介绍java5以来多线程开发的一些新变化。部分文字、代码都是摘抄、提炼过来的,大家有兴趣可...
入坑笔记,劝退一波,别搞后端了,转算法去吧! Java 设计模式 算法 网络 操作系统 数据库 Spring 分布式 大数据 目录 Java 1. 基础 基础:数据与程序结构、关键字等。 对象与类:继承、接口、抽象类、内部类、枚举...
做的学习笔记,并加入了自己的理解,谢谢 使用线程池的原因 我们创建的线程在运行结束后都会被虚拟机销毁,如果线程数量多的话,频繁的创建和销毁线程会大大浪费时间和效率,更重要的是浪费内存,线程池可以让线程...
1 适合初级进阶 2 简单的总结记录 3 涵盖 java8新特性lambda,Stream API,Try-with-resource,Guava,线程池,Loombok,验证框架
[目录]Java学习笔记(推荐) 6. [目录]JDBC文档 7. [目录]RMI 文档 2. [目录]Java资源(文档-书籍-下载-注册码) 1. [目录]License 和注册码 2. [目录]好书推荐 3. [目录]关于Java的...