SpringBoot_线程池_ThreadPoolTaskExecutor-程序员宅基地

1. 线程池配置

import org.springframework.context.annotation.Bean;

import org.springframework.context.annotation.Configuration;

import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;

/**

* 线程池配置

* @author xiangni123

*

*/

@Configuration

public class ExecutorConfig {

private static int CORE_POOL_SIZE = 5;

private static int MAX_POOL_SIZE = 1000;

@Bean(name="taskExecutor")

public ThreadPoolTaskExecutor taskExecutor(){

ThreadPoolTaskExecutor poolTaskExecutor = new ThreadPoolTaskExecutor();

//线程池维护线程的最少数量

poolTaskExecutor.setCorePoolSize(CORE_POOL_SIZE);

//线程池维护线程的最大数量

poolTaskExecutor.setMaxPoolSize(MAX_POOL_SIZE);

//线程池所使用的缓冲队列

poolTaskExecutor.setQueueCapacity(200);

//线程池维护线程所允许的空闲时间

poolTaskExecutor.setKeepAliveSeconds(30000);

poolTaskExecutor.setWaitForTasksToCompleteOnShutdown(true);

return poolTaskExecutor;

}

}

2.相关线程

import org.slf4j.Logger;

import org.slf4j.LoggerFactory;

public class WxTestThread implements Runnable {

private static final Logger logger = LoggerFactory.getLogger(WxTestThread.class);

@Override

public void run() {

logger.info("执行线程！");

}

}

3.线程调用处

import org.slf4j.Logger;

import org.slf4j.LoggerFactory;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;

import org.springframework.web.bind.annotation.RequestMapping;

import org.springframework.web.bind.annotation.RequestMethod;

import org.springframework.web.bind.annotation.RestController;

import org.springframework.web.servlet.ModelAndView;

import com.haoyi.demo.controller.HelloWorldController;

import com.haoyi.weixin.thread.WxTestThread;

@RestController

@RequestMapping("wxTest")

public class WxTestController {

private static final Logger logger = LoggerFactory.getLogger(WxTestController.class);

@Autowired

private ThreadPoolTaskExecutor taskExecutor;

@RequestMapping(value="helloWx")

public ModelAndView helloWx(){

logger.info("hello weixin!!!");

return new ModelAndView("wx/helloWeixin");

}

/**

* http://10.0.110.40:8088/wxTest/helloWxThread

* @return

*/

@RequestMapping(value = "helloWxThread", method = RequestMethod.GET)

public void helloWxThread(){

logger.info("hello weixin!!!");

setWxTestThread();

}

public void setWxTestThread(){

WxTestThread testThread = new WxTestThread();

taskExecutor.execute(testThread);

}

}

本文链接：https://blog.csdn.net/shuzhupeng/article/details/79163932

原作者删帖不实内容删帖广告或垃圾文章投诉

智能推荐

C++ HashMap和Map的区别_c/c++ 红黑树map hash map-程序员宅基地

文章浏览阅读4.7k次，点赞5次，收藏17次。今天想查一下c++ hashmap的使用方法，搜出来的一些文章实在辣眼睛，竟然很多都混淆了c++中map和hashmap的区别。首先，c++ 标准库的std::map内部是排序的，内部使用的是红黑树实现，不管是增加还是查找的时间复杂度 O(logN)O(logN)O(logN)。而c++ 标准库的hashmap其实叫作std::unordered_map，其增加和查询的时间复杂度才是 O(1)..._c/c++ 红黑树map hash map

nginx配置ssl证书实现https访问_nginx 配置https-程序员宅基地

文章浏览阅读3.1w次，点赞15次，收藏123次。配置ssl证书之前，先准备SSL证书，至于获取的途径很多（阿里云的服务，第三方服务购买）。这里不详细解释。以下是我的SSL证书准备好证书后，找到nginx的安装目录，我的安装位置为：/usr/local/nginx进入 config/nginx.conf如果没有装winscp（一款可视化文件操作工具）的。可以通过命令行的方式，编辑nginx的config文件。开始配置文件的修改在修改配置文件之前，最好做一个备份，防止修改错误，也能及时回退错误1、找到第一个监听.._nginx 配置https

Vue环境搭建及项目创建_在html 搭建vue环境-程序员宅基地

文章浏览阅读340次，点赞2次，收藏3次。一、环境搭建1.引入 vue 有三种方式：在编写 html 时可以通过 Vue.js 官网直接下载 vue.min.js 文件并用 script 标签引入使用 cdn 方式<script src="https://cdn.jsdelivr.net/npm/vue/dist/vue.js"></script><script src="h_在html 搭建vue环境

国内EDA软件公司有哪些？-程序员宅基地

文章浏览阅读1.8k次。EDA：Electronic Design Automation，电子设计自动化。电子设计自动化是指利用计算机辅助设计（CAD）软件，来完成超大规模集成电路（VLSI）芯片的功能设计、综合..._全芯制造

mysql高可用详解（八）：数据分片-程序员宅基地

文章浏览阅读3.4k次。分片技术的背景：横向扩展的方式可以很好的解决读负载的操作，但是无法解决写负载增加的问题；【将数据库分解的方式】功能分隔：将某些表分别放在不同的机器上；水平分隔：将某些表分隔成不同的行分别存储在不同的机器上；【数据分片】扩展写操作最直接的方法就是服务器之间不再有复制机制，这样它们就是完全分离的。通过这种结构，就可以将数据分成两个完全独立的自己，然后将客户端定向到它试图改变的数据所...

带进度条的按钮-程序员宅基地

文章浏览阅读911次。一、定义ProgressButton的自定义属性在attrs文件中定义ProgressButton的基本属性：主要有进度条颜色、进度条的背景颜色、按钮正常和被点击状态时的颜色、按钮的边角半径和是否显示进度信息。二、继承Button自定义ProgressButtonpackage com.cx_带进度条的按钮