JDK线程池和Spring线程池的使用实例解析

JDK线程池和Spring线程池的使用实例解析

这篇文章主要介绍了JDK线程池和Spring线程池的使用实例解析,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下

JDK线程池和Spring线程池实例，异步调用，可以直接使用

(1)JDK线程池的使用，此处采用单例的方式提供，见示例：

public class ThreadPoolUtil {

private static int corePoolSize = 5;

private static int maximumPoolSize = 10;

neAYAGBprivate static long keepAliveTime = 60L;

private static TimeUnit unit = TimeUnit.SECONDS;

private static int capacity = 1024;

private static ThreadFactory namedThreadFactory = new ThreadFactoryBuilder().setNameFormat("jdk-thread-pool-%d").build();

private static final ExecutorService executorService = new ThreadPoolExecutor(corePoolSize,

maximumPoolSize,

keepAliveTime,

unit,

new LinkedBlockingQueue<>(capacity),

namedThreadFactory,

new ThreadPoolExecutor.AbortPolicy());

private ThreadPoolUtil () {

}

public static ExecutorService getExecutorService () {

return executorService;

}

}

在其它地方可以直接这样使用：

ThreadPoolUtil.getExecutorService().execute(() -> {

System.out.println("test1");

System.out.println("test2");

}

)

(2)Spring线程池的使用，此处通过配置类的方式配置线程池的相关属性，见示例：

@Configuration

@EnableAsync

public class DocataThreadBeanConfig {

private int corePoolSize = 5;

private int maxPoolSize = 10;

private int queueCapacity = 1024;

private String namePrefix = "async-service-task-";

// 上述属性可以通过@Value来读取配置值

@Bean(name = "asyncServiceTaskExecutor")

public TaskExecutor asyncServiceExecutor() {

ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();

// 设置核心线程数

executor.setCorePoolSize(corePoolSize);

// 设置最大线程数

executor.setMaxPoolSize(maxPoolSize);

// 设置队列容量

executor.setQueueCapacity(queueCapacity);

// 设置线程活跃时间（秒）

executor.setKeepAliveSeconds(60);

// 设置默认线程名称

executor.setThreadNamePrefix(namePrefix);

// 设置拒绝策略

executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());

// 等待所有任务结束后再关闭线程池

executor.setWaitForTasksToCompleteOnShutdown(true);

executor.initialize();

;

return executor;

}

}

在其它文件中需要这样使用：

@Resource(name="asyncServiceTaskExecutor")

private ThreadPoolTaskExecutor asyncServiceTaskExecutor;

不要直接使用@Autowired，否则会提示失败的

@Autowired

private ThreadPoolTaskExecutor asyncServiceTaskExecutor;

版权声明：本文内容由网络用户投稿，版权归原作者所有，本站不拥有其著作权，亦不承担相应法律责任。如果您发现本站中有涉嫌抄袭或描述失实的内容，请联系我们jiasou666@gmail.com 处理，核实后本网站将在24小时内删除侵权内容。