扩展SPRING 2.0的threadPooltaskExecutor
public class MyThreadPoolTaskExecutor implements SchedulingTaskExecutor,Executor, InitializingBean, DisposableBean {
public void afterPropertiesSet() {
initialize();
}
public void initialize() {
BlockingQueue queue = createQueue(queueCapacity);
executorService = new ThreadPoolExecutor(corePoolSize,
maxPoolSize,keepAliveSeconds, TimeUnit.SECONDS, queue,
threadFactory,rejectedExecutionHandler);
threadPoolMap.put(this.getThreadPoolName(), this);
}
public boolean prefersShortLivedTasks() {
return true;
}
public void destroy() {
shutdown();
}
public void shutdown() {
executorService.shutdown();
}
public String getThreadPoolName() {
return threadPoolName;
}
public void setThreadPoolName(String threadPoolName) {
this.threadPoolName = threadPoolName;
}
public int getQueueCapacity() {
return queueCapacity;
}
public static Map getThreadPoolMap(){
return threadPoolMap;
}
}
<!-- 线程池进行初始化 -->
<bean id="beenCoverTaskExecutor" class="com.threadpool.MyThreadPoolTaskExecutor">
<!-- 核心线程数,默认为1 -->
<property name="corePoolSize" value="5" />
<!-- 最大线程数,默认为Integer.MAX_VALUE -->
<property name="maxPoolSize" value="10" />
<!-- 队列最大长度,一般需要设置值>=notifyScheduledMainExecutor.maxNum;默认为Integer.MAX_VALUE -->
<property name="queueCapacity" value="50000" />
<!-- 线程池维护线程所允许的空闲时间,默认为60s -->
<property name="keepAliveSeconds" value="300" />
<!-- 线程池名称 -->
<property name="threadPoolName" value="beenCoverTaskExecutor" />
<!-- 线程池对拒绝任务(无线程可用)的处理策略,目前只支持AbortPolicy、CallerRunsPolicy;默认为后者 -->
<property name="rejectedExecutionHandler">
<!-- AbortPolicy:直接抛出java.util.concurrent.RejectedExecutionException异常 -->
<!-- CallerRunsPolicy:主线程直接执行该任务,执行完之后尝试添加下一个任务到线程池中,可以有效降低向线程池内添加任务的速度 -->
<!-- DiscardOldestPolicy:抛弃旧的任务、暂不支持;会导致被丢弃的任务无法再次被执行 -->
<!-- DiscardPolicy:抛弃当前任务、暂不支持;会导致被丢弃的任务无法再次被执行 -->
<bean class="java.util.concurrent.ThreadPoolExecutor$DiscardOldestPolicy" />
</property>
</bean>
分享到:
相关推荐
在IT行业中,分布式架构是一种常见的解决方案,特别是在大数据处理和高并发场景下,它能有效提升系统的性能和可扩展性。本项目围绕“Java简单分布式架构,多个数据源,线程池多线程访问”这一主题展开,旨在通过利用...
### 基于MINA构建高性能的NIO应用 #### 概述 MINA作为一款优秀的客户端/服务器架构下的Java服务器框架,凭借其强大的功能和灵活性,在开发高性能网络应用程序方面表现突出。本文将深入探讨MINA的核心概念、优势...
总的来说,Spring的线程池支持和任务调度为开发者提供了强大的工具,帮助他们构建可扩展、高性能且易于管理的企业级应用。通过`TaskExecutor`和`ThreadPoolTaskScheduler`,开发者可以在不牺牲灵活性的前提下,确保...
ActiveMQ 是一个开源的消息中间件,它遵循开放消息模型(JMS)标准,提供高性能、高可用性和可扩展性的消息传递服务。在这个项目中,我们看到的是一个自己实现的 ActiveMQ 客户端,它特别关注多线程的实现,这在处理...
在本项目中,我们探索了如何将Spring MVC框架与多线程、线程池和Apache Kafka集成,构建一个高效的数据处理系统。以下是关于这些技术及其整合的详细知识点: 1. **Spring MVC**: - Spring MVC是Spring框架的一个...
在IT行业中,Java是一种广泛应用的编程语言,尤其在构建高性能、高并发的服务器架构方面具有显著优势。本资源集合包含了关于“JAVA高性能高并发服务器架构”的PDF文档和视频,旨在帮助开发者深入理解如何利用Java...
在Spring Boot应用中,我们可以利用其提供的功能来配置和管理定时任务、线程池以及多线程池执行。这些配置对于构建高效、可扩展的应用至关重要,尤其是在处理并发和定时任务调度时。 首先,我们来看看如何配置基础...
在Java开发领域,构建高性能、高并发的Web应用是一项核心任务。这涉及到多个技术层面的综合运用,包括但不限于系统架构设计、线程管理、数据访问优化、缓存策略、负载均衡以及性能监控等。以下是一些关键的知识点,...
在本课程中,"Spring Boot《Java课程》多线程教学演示系统(011733)",我们将深入探讨Java编程语言的核心特性之一——多线程,并结合Spring Boot框架构建一个实际的教学演示系统。这个系统将帮助我们理解如何在现代...
7. **MySQL数据库**:MySQL是最常用的开源关系型数据库之一,学习其SQL语法、索引优化、事务处理、存储引擎、性能监控和调优等知识,对于构建高性能、高可用的数据存储系统至关重要。 以上各知识点的学习和掌握,将...
在Java世界中,开发高性能、高并发的Web应用程序是一项关键任务,这关乎到系统的稳定性、扩展性和用户体验。本文将深入探讨如何借助Java技术栈来实现这一目标。 首先,选择合适的框架至关重要。Spring Boot是一个...
总结,这个Java实现的项目为大规模的网络爬虫工作提供了高性能、可扩展的解决方案,通过代理IP池解决了IP限制问题,采用分布式架构保证了系统的稳定性和高吞吐量,是企业级网络爬虫项目的优秀实践。
总结起来,这个项目展示了如何利用Spring Boot和Druid实现多数据源切换,以及如何在Spring Boot中配置和使用多线程来提升数据库操作的并发性能。对于初学者,这是一个很好的学习资源,可以深入理解Spring Boot的自动...
总的来说,基于Spring的Mina框架结合了Spring的灵活性和Mina的高性能,为企业级的网络通信服务提供了强大的解决方案。开发者可以通过熟练掌握这两个框架的整合,构建出稳定、可扩展的网络应用。
Redis是高性能的键值数据库,常用于数据缓存、分布式锁和消息中间件等场景。在Redis中,你可以存储字符串、列表、集合、哈希表和有序集合等多种数据结构,并利用其原子操作来保证数据的一致性。例如,你可以用`SET`...
这些技术都是在构建高性能、可扩展的分布式系统中常用的工具。 首先,Kestrel是一个开源的、基于内存的分布式消息队列系统,它主要由Twitter开发并维护。Kestrel以其高吞吐量和低延迟而著名,被广泛用于构建实时...
以上是构建高性能、高并发Java Web应用的核心知识点。通过合理运用这些技术和工具,可以有效地提升系统的吞吐量和响应速度,同时保证系统的稳定性和可扩展性。在实际开发中,应根据项目需求灵活选择并整合这些技术,...
总结起来,构建Java高并发高性能分布式框架和微服务架构,需要深入了解和运用包括但不限于Spring框架、线程池、NIO、缓存策略、Dubbo、Zookeeper、Spring Cloud、数据一致性模型以及CI/CD等技术。通过合理的设计和...
在构建一个基于Spring的简单高效通用异步任务处理系统时,我们的主要目标是实现轻量级、简单、高效、通用、高扩展性和高可靠性的解决方案。在这个系统中,我们将利用Spring框架的功能,如Job调度和线程池封装,以及...
总结,Spring Framework 3.2.x是一个功能强大、高度可扩展的框架,它的设计思想和实践模式对Java开发者来说具有极高的学习价值。理解并熟练运用其中的知识点,不仅能提升开发效率,还能更好地实现代码的可维护性和可...