- 浏览: 50373 次
- 性别:
文章分类
- 全部博客 (103)
- 一致性哈希算法 (1)
- 云计算 (2)
- Cassandra学习 (2)
- Java网络通信与笔记 (14)
- ZooKeeper学习 (1)
- HBase学习 (1)
- Sqoop学习 (1)
- Java网页开发之 (2)
- Java网络通信框架 (5)
- (memcached)分布式内存对象缓存系统 (1)
- Redis学习 (5)
- Shell学习 (14)
- Linux学习 (10)
- MySQL优化 (17)
- C++ (7)
- HTML5 (5)
- Android学习 (5)
- 网络 (2)
- Node.js (1)
- D3.js (1)
- R语言学习 (3)
- Spark (1)
- CAN协议 (2)
- 解决方案 (0)
最新评论
Java线程池使用说明
一简介
线程的使用在java中占有极其重要的地位,在jdk1.4极其之前的jdk版本中,关于线程池的使用是极其简陋的。在jdk1.5之后这一情况有了很大的改观。Jdk1.5之后加入了java.util.concurrent包,这个包中主要介绍java中线程以及线程池的使用。为我们在开发中处理线程的问题提供了非常大的帮助。
二:线程池
线程池的作用:
线程池作用就是限制系统中执行线程的数量。
根据系统的环境情况,可以自动或手动设置线程数量,达到运行的最佳效果;少了浪费了系统资源,多了造成系统拥挤效率不高。用线程池控制线程数量,其他线程排队等候。一个任务执行完毕,再从队列的中取最前面的任务开始执行。若队列中没有等待进程,线程池的这一资源处于等待。当一个新任务需要运行时,如果线程池中有等待的工作线程,就可以开始运行了;否则进入等待队列。
为什么要用线程池:
1.减少了创建和销毁线程的次数,每个工作线程都可以被重复利用,可执行多个任务。
2.可以根据系统的承受能力,调整线程池中工作线线程的数目,防止因为消耗过多的内存,而把服务器累趴下(每个线程需要大约1MB内存,线程开的越多,消耗的内存也就越大,最后死机)。
Java里面线程池的顶级接口是Executor,但是严格意义上讲Executor并不是一个线程池,而只是一个执行线程的工具。真正的线程池接口是ExecutorService。
比较重要的几个类:
ExecutorService是真正的线程池接口。
ScheduledExecutorService能和Timer/TimerTask类似,解决那些需要任务重复执行的问题。
ThreadPoolExecutor是ExecutorService的默认实现。
ScheduledThreadPoolExecutor继承ThreadPoolExecutor的ScheduledExecutorService接口实现,周期性任务调度的类实现。
要配置一个线程池是比较复杂的,尤其是对于线程池的原理不是很清楚的情况下,很有可能配置的线程池不是较优的,因此在Executors类里面提供了一些静态工厂,生成一些常用的线程池。
1. newSingleThreadExecutor
创建一个单线程的线程池。这个线程池只有一个线程在工作,也就是相当于单线程串行执行所有任务。如果这个唯一的线程因为异常结束,那么会有一个新的线程来替代它。此线程池保证所有任务的执行顺序按照任务的提交顺序执行。
2.newFixedThreadPool
创建固定大小的线程池。每次提交一个任务就创建一个线程,直到线程达到线程池的最大大 小。线程池的大小一旦达到最大值就会保持不变,如果某个线程因为执行异常而结束,那么线程池会补充一个新线程。
3. newCachedThreadPool
创建一个可缓存的线程池。如果线程池的大小超过了处理任务所需要的线程,
那么就会回收部分空闲(60秒不执行任务)的线程,当任务数增加时,此线程池又可以智能的添加新线程来处理任务。此线程池不会对线程池大小做限制,线程池大小完全依赖于操作系统(或者说JVM)能够创建的最大线程大小。
4.newScheduledThreadPool
创建一个大小无限的线程池。此线程池支持定时以及周期性执行任务的需求。
实例
1:newSingleThreadExecutor
MyThread.java
publicclassMyThread extends Thread {
@Override
publicvoid run() {
System.out.println(Thread.currentThread().getName() + "正在执行。。。");
}
}
TestSingleThreadExecutor.java
publicclassTestSingleThreadExecutor {
publicstaticvoid main(String[] args) {
//创建一个可重用固定线程数的线程池
ExecutorService pool = Executors. newSingleThreadExecutor();
//创建实现了Runnable接口对象,Thread对象当然也实现了Runnable接口
Thread t1 = new MyThread();
Thread t2 = new MyThread();
Thread t3 = new MyThread();
Thread t4 = new MyThread();
Thread t5 = new MyThread();
//将线程放入池中进行执行
pool.execute(t1);
pool.execute(t2);
pool.execute(t3);
pool.execute(t4);
pool.execute(t5);
//关闭线程池
pool.shutdown();
}
}
输出结果
pool-1-thread-1正在执行。。。
pool-1-thread-1正在执行。。。
pool-1-thread-1正在执行。。。
pool-1-thread-1正在执行。。。
pool-1-thread-1正在执行。。。
2:newFixedThreadPool
TestFixedThreadPool.Java
publicclass TestFixedThreadPool {
publicstaticvoid main(String[] args) {
//创建一个可重用固定线程数的线程池
ExecutorService pool = Executors.newFixedThreadPool(2);
//创建实现了Runnable接口对象,Thread对象当然也实现了Runnable接口
Thread t1 = new MyThread();
Thread t2 = new MyThread();
Thread t3 = new MyThread();
Thread t4 = new MyThread();
Thread t5 = new MyThread();
//将线程放入池中进行执行
pool.execute(t1);
pool.execute(t2);
pool.execute(t3);
pool.execute(t4);
pool.execute(t5);
//关闭线程池
pool.shutdown();
}
}
输出结果
pool-1-thread-1正在执行。。。
pool-1-thread-2正在执行。。。
pool-1-thread-1正在执行。。。
pool-1-thread-2正在执行。。。
pool-1-thread-1正在执行。。。
3: newCachedThreadPool
TestCachedThreadPool.java
publicclass TestCachedThreadPool {
publicstaticvoid main(String[] args) {
//创建一个可重用固定线程数的线程池
ExecutorService pool = Executors.newCachedThreadPool();
//创建实现了Runnable接口对象,Thread对象当然也实现了Runnable接口
Thread t1 = new MyThread();
Thread t2 = new MyThread();
Thread t3 = new MyThread();
Thread t4 = new MyThread();
Thread t5 = new MyThread();
//将线程放入池中进行执行
pool.execute(t1);
pool.execute(t2);
pool.execute(t3);
pool.execute(t4);
pool.execute(t5);
//关闭线程池
pool.shutdown();
}
}
输出结果:
pool-1-thread-2正在执行。。。
pool-1-thread-4正在执行。。。
pool-1-thread-3正在执行。。。
pool-1-thread-1正在执行。。。
pool-1-thread-5正在执行。。。
4:newScheduledThreadPool
TestScheduledThreadPoolExecutor.java
publicclass TestScheduledThreadPoolExecutor {
publicstaticvoid main(String[] args) {
ScheduledThreadPoolExecutor exec = new ScheduledThreadPoolExecutor(1);
exec.scheduleAtFixedRate(new Runnable() {//每隔一段时间就触发异常
@Override
publicvoid run() {
//throw new RuntimeException();
System.out.println("================");
}
}, 1000, 5000, TimeUnit.MILLISECONDS);
exec.scheduleAtFixedRate(new Runnable() {//每隔一段时间打印系统时间,证明两者是互不影响的
@Override
publicvoid run() {
System.out.println(System.nanoTime());
}
}, 1000, 2000, TimeUnit.MILLISECONDS);
}
}
输出结果
================
8384644549516
8386643829034
8388643830710
================
8390643851383
8392643879319
8400643939383
发表评论
-
Java之Concurrent(并发)包
2015-09-25 16:31 314因为实在是太多了,太长了,一时间无法自习整理和消化,先 ... -
Java集合框架
2015-09-25 16:31 390集合框架有很多的 ... -
final, finally, finalize的区别
2015-09-19 11:39 3861.final final修饰类,说明 ... -
四种会话跟踪技术
2015-09-19 11:36 773会话跟踪是一种灵活、轻便的机制,它使Web上的状态编程变为可能 ... -
java中volatile关键字的含义
2015-09-19 10:59 376在java线程并发处理中, ... -
java笔记--关于线程同步(5种同步方式)
2015-09-19 10:21 414[size=medium]为何要使用同步? java ... -
RPC
2015-07-30 11:04 387RPC 功能目标 RPC 的 ... -
Java NIO原理文分析及代码实现
2015-07-22 10:43 428Java NIO原理图文分析及代码实现 前言: 最近在分 ... -
NIO学习(一)
2015-07-22 10:43 326[size=medium]NIO学习 一.NIO中的几个基础 ... -
Java IO浅谈
2015-07-21 13:12 305Java IO浅谈 [size=large] ... -
线程池(一)
2015-07-21 12:11 362线程池 在上一篇博客中,我们有提及阻塞IO的为每个连接请求 ... -
多种IO设计模式
2015-07-21 11:45 450Java通信的几种IO设计 [size=large]阻塞IO ... -
阻塞与非阻塞-----同步与异步
2015-07-21 11:31 479阻塞(blocking)与非阻塞(non-blocking)I ...
相关推荐
二、实现线程池可以按照以下步骤进行 三、简单的C++线程池代码示例 四、 基于boost编写的源码库 - 线程池 4.1 基于boost编写的源码库地址 4.2 boost线程池的先进先出、后进先出、优先级代码示例 五、看看人家线程池...
### 二、Quartz 线程池的工作流程 1. **初始化线程池**:在应用启动时,Quartz 会根据配置信息创建线程池。线程池大小可以根据系统的负载和需求进行调整,以平衡资源利用率和响应速度。 2. **任务分配**:当一个 ...
二、ConsumeThreadPoolPara 的 javabean `ConsumeThreadPoolPara` 是一个 JavaBean,用于存储线程池的参数,包括最小和最大线程数、检查线程池中线程的周期等参数。该类实现了 Serializable 接口,用于序列化和反...
#### 二、使用线程池的好处 使用线程池的主要好处包括: 1. **减少在创建和销毁线程上的时间和资源开销**:每次创建和销毁线程都会消耗大量的CPU时间和内存资源。通过使用线程池,可以显著减少这些开销。 2. **...
线程池在IT行业中是一种非常重要的并发编程技术,尤其在多任务处理和资源管理上具有高效性和灵活性。本文将深入探讨Windows线程池的实现,重点关注其策略基础和实际应用。 Windows线程池是操作系统提供的一个服务,...
#### 二、传统多线程方案的问题 在传统的多线程服务器模型中,每当有新请求到达时,就会创建一个新的线程来处理这个请求。一旦请求处理完成,线程就会被销毁。这种“即时创建,即时销毁”的策略存在以下几个问题: ...
二、线程池工作机制 当一个任务通过 `execute(Runnable)` 方法被添加到线程池时,线程池会根据当前的情况来决定如何处理该任务。具体来说,线程池的工作机制可以分为以下几步: 1. 如果当前线程池中的数量小于 `...
#### 二、深入剖析线程池实现原理 线程池的实现原理主要包括以下几个方面: 1. **任务提交**:当任务提交到线程池时,线程池首先检查是否有足够的工作线程来处理任务。如果有,任务将被提交给一个可用的工作线程;...
8. `Bin` - 可能包含了编译好的二进制库文件,可以直接在Delphi项目中引用和使用。 通过分析这些文件,开发者可以获取到一个完整的线程池实现,了解如何在Delphi项目中集成和使用线程池,从而提升程序的并发性能。...
#### 二、线程池的基本概念 线程池是指预先创建一定数量的工作线程,并将它们置于空闲状态,以便随时可以用于执行任务。当有任务提交到线程池时,这些任务会被分配给空闲的线程执行。任务执行完毕后,线程并不会立即...
线程池(ThreadPool)是一种资源管理技术,它允许我们将任务分配到多个工作线程中,以提高程序执行效率并避免过度消耗系统资源。在给定的代码示例中,`myserver.cpp` 和 `mytask.cpp` 可能包含了使用线程池处理TCP...
#### 二、关键数据结构 在`thrmgr.h`头文件中定义了几个关键的数据结构,用于构建线程池。 1. **`work_item_t`**:工作项结构体,用于存储单个任务的信息,包括指向下一个工作项的指针、任务数据以及任务被加入...
二、单任务线程池 三、可变尺寸的线程池 四、延迟连接池 五、单任务延迟连接池 六、自定义线程池 Java线程:新特征-有返回值的线程 Java线程:新特征-锁(上) Java线程:新特征-阻塞队列 Java线程:新特征-...
#### 二、线程池的工作原理 线程池主要由以下几个核心组件构成: 1. **任务队列**:用于存储待处理的任务。 2. **工作线程**:预创建的线程集合,负责从任务队列中取出任务并执行。 3. **管理器**:控制线程池的...
二、Java的ExecutorService接口 Java的`java.util.concurrent`包提供了`ExecutorService`接口,它是线程池的主要入口。通过实现这个接口,我们可以控制线程的执行方式,如设置最大线程数、处理任务队列等。`...
#### 二、线程池的基本概念 线程池通过预创建一定数量的线程并在请求到来时分配这些线程来解决上述问题。这样可以显著减少线程创建和销毁的时间开销,并且可以通过控制并发线程的数量来避免资源过度消耗。线程池的...
#### 二、线程池基础知识 在深入探讨Tomcat 6.0中的线程池配置之前,有必要对线程池的基本概念进行简单回顾: - **线程池**:预先创建一定数量的线程,并存储在一个池子中,当有新的任务提交时,可以从池中取出一个...
二、线程池的优势 使用线程池可以带来以下几点优势: 1. 降低资源消耗:线程池可以重复利用已创建的线程,减少线程的创建和销毁成本。 2. 提高响应速度:任务到达时,任务可无须等待线程创建就能立即执行。 3. ...
二、CLR 与线程池 CLR 是专门用于创建托管代码环境,为在.NET 平台上运行的应用程序提供各种服务的,例如编译、垃圾收集、内存管理,还有线程池。确实,在定义宿主应用程序使用的线程的进程方面,Win32 和.NET ...
#### 二、线程池的作用与必要性 线程池的主要功能在于限制系统中执行线程的数量。合理设置线程池的规模可以避免因线程数量过多导致系统资源耗尽,或者因线程过少而无法充分利用系统资源的情况发生。通过使用线程池...