`

构建高性能工作线程 二 扩展 Spring 线程池

    博客分类:
  • java
 
阅读更多

扩展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>

 

分享到:
评论

相关推荐

    java简单分布式架构,多个数据源,线程池多线程访问

    在IT行业中,分布式架构是一种常见的解决方案,特别是在大数据处理和高并发场景下,它能有效提升系统的性能和可扩展性。本项目围绕“Java简单分布式架构,多个数据源,线程池多线程访问”这一主题展开,旨在通过利用...

    基于MINA构建高性能的NIO应用

    ### 基于MINA构建高性能的NIO应用 #### 概述 MINA作为一款优秀的客户端/服务器架构下的Java服务器框架,凭借其强大的功能和灵活性,在开发高性能网络应用程序方面表现突出。本文将深入探讨MINA的核心概念、优势...

    Spring提供的线程池支持[借鉴].pdf

    总的来说,Spring的线程池支持和任务调度为开发者提供了强大的工具,帮助他们构建可扩展、高性能且易于管理的企业级应用。通过`TaskExecutor`和`ThreadPoolTaskScheduler`,开发者可以在不牺牲灵活性的前提下,确保...

    自己实现的 ActiveMQ 多线程客户端 包含生产消息客户端和消费者消息客户端

    ActiveMQ 是一个开源的消息中间件,它遵循开放消息模型(JMS)标准,提供高性能、高可用性和可扩展性的消息传递服务。在这个项目中,我们看到的是一个自己实现的 ActiveMQ 客户端,它特别关注多线程的实现,这在处理...

    springMVC+多线程+kafka的 demo基于maven

    在本项目中,我们探索了如何将Spring MVC框架与多线程、线程池和Apache Kafka集成,构建一个高效的数据处理系统。以下是关于这些技术及其整合的详细知识点: 1. **Spring MVC**: - Spring MVC是Spring框架的一个...

    JAVA高性能高并发服务器架构pdf文档视频资源

    在IT行业中,Java是一种广泛应用的编程语言,尤其在构建高性能、高并发的服务器架构方面具有显著优势。本资源集合包含了关于“JAVA高性能高并发服务器架构”的PDF文档和视频,旨在帮助开发者深入理解如何利用Java...

    Spring Boot中配置定时任务、线程池与多线程池执行的方法

    在Spring Boot应用中,我们可以利用其提供的功能来配置和管理定时任务、线程池以及多线程池执行。这些配置对于构建高效、可扩展的应用至关重要,尤其是在处理并发和定时任务调度时。 首先,我们来看看如何配置基础...

    利用Java开发高性能、高并发Web应用

    在Java开发领域,构建高性能、高并发的Web应用是一项核心任务。这涉及到多个技术层面的综合运用,包括但不限于系统架构设计、线程管理、数据访问优化、缓存策略、负载均衡以及性能监控等。以下是一些关键的知识点,...

    spring boot《Java课程》多线程教学演示系统(011733)

    在本课程中,"Spring Boot《Java课程》多线程教学演示系统(011733)",我们将深入探讨Java编程语言的核心特性之一——多线程,并结合Spring Boot框架构建一个实际的教学演示系统。这个系统将帮助我们理解如何在现代...

    软件工程师的学习笔记,包含网络、操作系统、设计模式、JVM、多线程与高并发、Spring、MySQL......zip

    7. **MySQL数据库**:MySQL是最常用的开源关系型数据库之一,学习其SQL语法、索引优化、事务处理、存储引擎、性能监控和调优等知识,对于构建高性能、高可用的数据存储系统至关重要。 以上各知识点的学习和掌握,将...

    java_如何利用Java开发高性能、高并发Web应用

    在Java世界中,开发高性能、高并发的Web应用程序是一项关键任务,这关乎到系统的稳定性、扩展性和用户体验。本文将深入探讨如何借助Java技术栈来实现这一目标。 首先,选择合适的框架至关重要。Spring Boot是一个...

    基于Java的高性能、支持免费http代理池、支持横向扩展、分布式爬虫项目.zip

    总结,这个Java实现的项目为大规模的网络爬虫工作提供了高性能、可扩展的解决方案,通过代理IP池解决了IP限制问题,采用分布式架构保证了系统的稳定性和高吞吐量,是企业级网络爬虫项目的优秀实践。

    Springboot Druid多数据源 多线程

    总结起来,这个项目展示了如何利用Spring Boot和Druid实现多数据源切换,以及如何在Spring Boot中配置和使用多线程来提升数据库操作的并发性能。对于初学者,这是一个很好的学习资源,可以深入理解Spring Boot的自动...

    基于spring的Mina框架

    总的来说,基于Spring的Mina框架结合了Spring的灵活性和Mina的高性能,为企业级的网络通信服务提供了强大的解决方案。开发者可以通过熟练掌握这两个框架的整合,构建出稳定、可扩展的网络应用。

    Redis、Spring、RabbitMQ、Java线程、Mybatis、HashMap、JVM、MySQL相关问题的实例代码

    Redis是高性能的键值数据库,常用于数据缓存、分布式锁和消息中间件等场景。在Redis中,你可以存储字符串、列表、集合、哈希表和有序集合等多种数据结构,并利用其原子操作来保证数据的一致性。例如,你可以用`SET`...

    征服 Kestrel + XMemcached + Spring TaskExecutor

    这些技术都是在构建高性能、可扩展的分布式系统中常用的工具。 首先,Kestrel是一个开源的、基于内存的分布式消息队列系统,它主要由Twitter开发并维护。Kestrel以其高吞吐量和低延迟而著名,被广泛用于构建实时...

    如何利用Java开发高性能、高并发Web应用

    以上是构建高性能、高并发Java Web应用的核心知识点。通过合理运用这些技术和工具,可以有效地提升系统的吞吐量和响应速度,同时保证系统的稳定性和可扩展性。在实际开发中,应根据项目需求灵活选择并整合这些技术,...

    Java高并发高性能分布式框架从无到有微服务架构设计.docx

    总结起来,构建Java高并发高性能分布式框架和微服务架构,需要深入了解和运用包括但不限于Spring框架、线程池、NIO、缓存策略、Dubbo、Zookeeper、Spring Cloud、数据一致性模型以及CI/CD等技术。通过合理的设计和...

    基于Spring打造简单高效通用的异步任务处理系统

    在构建一个基于Spring的简单高效通用异步任务处理系统时,我们的主要目标是实现轻量级、简单、高效、通用、高扩展性和高可靠性的解决方案。在这个系统中,我们将利用Spring框架的功能,如Job调度和线程池封装,以及...

    spring-framework-3.2.x.zip

    总结,Spring Framework 3.2.x是一个功能强大、高度可扩展的框架,它的设计思想和实践模式对Java开发者来说具有极高的学习价值。理解并熟练运用其中的知识点,不仅能提升开发效率,还能更好地实现代码的可维护性和可...

Global site tag (gtag.js) - Google Analytics