文章目錄

• 1.介紹
• • 配置類
  • 業務層
  • 控制層

1.介紹

在Spring中存在一個AsyncConfigurer接口，它是一個可以配置異步線程池的接口，因此只需要Java配置文件，實現AsyncConfigurer接口，實現getAsyncExecutor方法返回的線程池，這樣Spring就會將使用這個線程池作為其異步調用的線程。為了使得異步可用，Spring還提供一個注解@EnableAsync，如果Java配置文件標注它，那么Spring就會開啟異步可用，這樣就可以使用注解@Async驅動Spring使用異步調用，下節我們會看到這樣的實例。
　
異步實例
使用Java配置定義線程池和啟用異步

配置類

package com.springboot.chapter13.config; /**** imports ****/ @Configuration @EnableAsync public class AsyncConfig implements AsyncConfigurer {// 定義線程池@Overridepublic Executor getAsyncExecutor() {// 定義線程池ThreadPoolTaskExecutor taskExecutor = new ThreadPoolTaskExecutor();// 核心線程數taskExecutor.setMaxPoolSize(10);//最大線程數taskExecutor.setQueueCapacity(100);//線程隊列最大線程數taskExecutor.initialize();return taskExecutor;} }

在代碼中，注解@EnableAsync代表開啟Spring異步。這樣就可以使用@Async驅動Spring使用異步，但是異步需要提供可用線程池，所以這里的配置類還會實現AsyncConfigurer接口，然后覆蓋getAsyncExecutor方法，這樣就可以自定義一個線程池。因此當方法被標注@Async時，Spring就會通過這個線程池的空閑線程去運行該方法。在getAsyncExecutor方法中創建了線程池，設置了其核心線程、最大線程數、線程隊列的限制，然后將線程池初始化，這樣異步便可用。

業務層

public interface AsyncService {//異步服務接口public void generateReport(); } @Service public class AsyncServiceImpl implements AsyncService { @Autowired private ISongService songService;@Override@Async//聲明異步調用public void generateReport() { songService.CacheToSql();System.out.println(Thread.currentThread().getName());} }

CacheToSql為一個自定義的將redis中數據寫入數據庫的方法：

@Override public int CacheToSql() {List<UserSong>userSongs = null;User principal = (User) SecurityUtils.getSubject().getPrincipal();Map<String, Object> likeCountMap = redisService.hGetAll("user:" + principal.getId());int insertRecord= 0;for(Map.Entry entry:likeCountMap.entrySet()) {String key = (String) entry.getKey();String songid = key.split(":")[1];Song song = this.getOne(new LambdaQueryWrapper<Song>().eq(Song::getId, songid));Integer count = (Integer) entry.getValue();UserSong userSong = userSongService.selectByUserAndSong(principal.getId(),song.getId());if(Objects.nonNull(userSong)){userSong.setPlayCount(count);userSongService.saveOrUpdate(userSong);}else {userSong = new UserSong();userSong.setSongId(song.getId());userSong.setUserId(principal.getId());userSong.setPlayCount(count);userSongService.save(userSong);insertRecord++;}System.out.println(userSong);}// userSongs.stream().forEach(System.out::println);return insertRecord; }

控制層

@PostMapping("/play/{songId}")public ResponseResult<?> playSong(@PathVariable("songId") Integer songId){songService.playSong(songId);asyncService.generateReport();return ResponseResult.success();}

運行后訪問相關路徑，查看結果：

可以看到輸出的ThreadPoolTaskExecutor-2為當前正運行的異步線程

總結

以上是生活随笔為你收集整理的springboot使用异步线程池执行自定义任务实例的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。