This commit is contained in:
xiangwbs
2018-03-11 14:22:52 +08:00
parent 0738b7ae2a
commit a08e138af9
2 changed files with 2 additions and 5 deletions
@@ -1,8 +1,6 @@
package com.xwbing.demo;
import com.alibaba.fastjson.JSONObject;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
import javax.annotation.Resource;
@@ -19,8 +17,7 @@ import java.util.stream.Collectors;
*/
public class LambdaDemo {
@Resource
private static ThreadPoolTaskExecutor taskExecutor;
private static final Logger logger = LoggerFactory.getLogger(LambdaDemo.class);
private ThreadPoolTaskExecutor taskExecutor;
public static void main(String[] args) {
//匿名内部类
@@ -52,7 +52,7 @@ public class ApplicationContextConfig {
* @return
*/
@Bean(name = "taskExecutor")
public static ThreadPoolTaskExecutor getPoolTaskExecutor() {
public ThreadPoolTaskExecutor getPoolTaskExecutor() {
ThreadPoolTaskExecutor poolTaskExecutor = new ThreadPoolTaskExecutor();
poolTaskExecutor.setCorePoolSize(5);//核心线程数
poolTaskExecutor.setMaxPoolSize(1000);//最大线程数