个人中心
文章发布
退出
作者热门文章
- ubuntu12.04环境下使用kvm ioctl接口实现最简单的虚拟机
- Ubuntu 通过无线网络安装Ubuntu Server启动系统后连接无线网络的方法
- 在Ubuntu上搭建网桥的方法
- ubuntu 虚拟机上网方式及相关配置详解
25
4
CFSDN坚持开源创造价值，我们致力于搭建一个资源共享平台，让每一个IT人在这里找到属于你的精彩世界.
这篇CFSDN的博客文章java ThreadPoolExecutor使用方法简单介绍由作者收集整理，如果你对这篇文章有兴趣，记得点赞哟.
java ThreadPoolExecutor 。
前言:
在项目中如果使用发短信这个功能，一般会把发短信这个动作变成异步的，因为大部分情况下，短信到底是发送成功或者失败，都不能影响主流程。当然像发送MQ消息等操作也是可以封装成异步操作的.
使用基本的New Thread 。
如果想一个操作变成异步的，可以直接new thread，然后在run方法中实现业务操作即可。例如:
|
1
2
3
4
5
|
new
Thread(
new
Runnable() {
public
void
run() {
//发短信、发MQ消息等
}
});
|
但是这种方式有几个缺点.
1.每次都会new一个线程，执行完后销毁，不能复用； 。
2.如果系统的并发量刚好比较大，需要大量线程，那么这种每次new的方式会抢资源的.
ThreadPoolExecutor 。
我们可以使用jdk1.5中的ThreadPoolExecutor来封装异步操作。ThreadPoolExecutor的好处是可以做到线程复用，并且使用尽量少的线程去执行更多的任务，效率和性能都相当不错。demo代码如下:
|
1
2
3
4
5
6
7
8
|
public
class
ThreadPool {
private
static
ThreadPoolExecutor threadPool =
new
ThreadPoolExecutor(
8
,
12
,
30
,
TimeUnit.SECONDS,
new
ArrayBlockingQueue<Runnable>(
50000
),
new
ThreadPoolExecutor.AbortPolicy());
public
static
ThreadPoolExecutor getThreadPool() {
return
threadPool;
}
}
|
参数介绍 。
|
1
2
3
4
5
6
7
8
|
public
ThreadPoolExecutor(
int
corePoolSize,
int
maximumPoolSize,
long
keepAliveTime,
TimeUnit unit,
BlockingQueue<Runnable> workQueue,
RejectedExecutionHandler handler) {
}
|
corePoolSize：当workQueue队列中的元素还未到达最大值时，corePoolSize表示的池中线程数量的最大值； maximumPoolSize：线程池中允许的最大线程数； keepAliveTime：当前池中的线程数如果超过了corePoolSize，那么超出那些线程如果空闲太久了，应该需要销毁的。keepAliveTime就是的是这些线程的最大空闲时间； unit：keepAliveTime的时间单位； workQueue：当池中线程数的数量已经达到了corePoolSize，那么如果请求还继续过来，会把请求对应的task放入队列中； handler：当workQueue满了，池中的线程数又达到了maximumPoolSize，这个时候已经没有多余的资源处理请求了，需要RejectedExecutionHandler 来处理。拒绝处理或者丢弃任务等等.
执行过程 。
当没有请求时，线程池中没有任何线程； 。
当有请求时，创建线程，一直到池中的线程数等于corePoolSize； 。
如果请求太多，需要更多的线程来处理的话，ThreadPoolExecutor选择把请求放入队列中，暂时不新建线程； 。
如果workQueue也满了，ThreadPoolExecutor会继续创建线程，直到线程数量跟maximumPoolSize相等； 。
线程数达到maximumPoolSize了，同时workQueue也慢了，就只能把请求丢给RejectedExecutionHandler 来处理.
备注 。
使用ThreadPoolExecutor时，需要根据自己的业务情况，适当的指定参数值的大小.
感谢阅读，希望能帮助到大家，谢谢大家对本站的支持！ 。
原文链接：http://blog.csdn.net/linsongbin1/article/details/51487811 。
最后此篇关于java ThreadPoolExecutor使用方法简单介绍的文章就讲到这里了,如果你想了解更多关于java ThreadPoolExecutor使用方法简单介绍的内容请搜索CFSDN的文章或继续浏览相关文章，希望大家以后支持我的博客！ 。
25
4
0
这是正确的吗？ ThreadPoolExecutor threadPoolExecutor = (ThreadPoolExecutor)
我只是对我编写的一些代码感到非常困惑。我惊讶地发现: with concurrent.futures.ThreadPoolExecutor(max_workers=4) as executor:
我正在尝试同时使用 InheritableThreadLocal 和 ThreadPoolExecutor。 这是因为 ThreadPoolExecutor 为每个池重用线程(毕竟它是一个池)，这意味
concurrent.futures.ThreadPoolExecutor 通过 传递 function 到执行器 executor.submit(my_function) 像这样: def my_f
将一个简单的测试程序放在一起，应该并行执行一些任务。每次我们提交6个任务，等待完成。然后，又提交了一组任务。 import java.util.concurrent.*; public class
我正在运行一段 python 代码，其中多个线程通过线程池执行程序运行。每个线程都应该执行一项任务(例如获取网页)。我想要做的是终止所有线程，即使其中一个线程失败。例如: with ThreadPoo
我有一个使用阻塞队列的ThreadPoolExecutor，并且正在尝试调试一个问题，在该问题中，我怀疑任务在ThreadPoolExecutor的队列中停留的时间太长，无法执行。我正在尝试验证这一理
我正在尝试使用 futures backport 包在 Python 中使用 ThreadPoolExecutor。然而，问题是所有线程都是同时执行的，所以没有实际的池化发生。更具体地说，我得到了该函
我有两个 list : a = [1, 2, 3, 4] b = [9, 8, 7, 6] 我希望将这两个列表的每个组合作为参数传递给我正在执行多线程处理的函数: def test(hello, wo
当我们谈论ThreadPoolExecutor时，核心池大小和最大池大小之间到底有什么区别？ 可以用例子来解释吗？ 最佳答案 来自this blog post : Take this example.
我对“concurrent.futures”的并行处理相当陌生，我正在测试一些简单的实验。我编写的代码似乎可以工作，但我不确定如何存储结果。我尝试创建一个列表(“ future ”)并将结果附加到该列
我审查了多线程，并尝试实现一个创建单独线程来运行收集进程的应用程序。该过程中的主要方法需要一个变量数组列表，我正在尝试找出一种将数组列表传递给每个线程的方法。 ApplicationContext c
很难说出这里问的是什么。这个问题是含糊的、模糊的、不完整的、过于宽泛的或修辞性的，无法以目前的形式得到合理的回答。如需帮助澄清此问题以便重新打开它，visit the help center 。 已关
我需要读取一个大的 csv 文件(328 MB)并对其进行处理。每行的处理还包括调用 Web 服务。 我是第一次使用ThreadPoolExecutor。我的逻辑是，我将从 csv 中每 100 行吐
from concurrent.futures import ThreadPoolExecutor, wait, ALL_COMPLETED def div_zero(x): print('I
我有一个带有 run 方法的类，该类的 main 方法中的计时器正在使用以下代码调用该类: Timer timer = new Timer(); timer.scheduleAtFixedRate(n
尝试调试竞争条件，其中我们的应用程序的轮询器线程之一永远不会返回，导致 future 的轮询器永远不会被调度。用抽象术语来说，在捕获问题时隐藏我们的业务逻辑，这就是我们的代码路径。 我们必须更新远程服
下面的错误是什么意思？我怎样才能恢复它？ Exception in thread "UserActionProcessor-8811" java.util.concurrent.RejectedExe
我正在致力于增强现有的 Java 应用程序。该应用程序是一个消息处理器，每天处理数百万条消息。它基本上是使用 Core Java 编写的，线程和队列是使用 Collection 类实现的。 在此应用程
我想更新使用用户定义线程池的旧代码。我想使用 java ThreadPoolExecutor，但问题是发送到线程池的请求不是可运行的。有什么方法可以将 ThreadPoolExecutor 与现有请求
我是一名优秀的程序员,十分优秀！