Selaa lähdekoodia

修改线程池的使用方式

hgw 3 vuotta sitten
vanhempi
commit
a7f307fb01

+ 2 - 2
mec-biz/src/main/java/com/ym/mec/biz/service/impl/EmployeeServiceImpl.java

@@ -406,7 +406,7 @@ public class EmployeeServiceImpl extends BaseServiceImpl<Integer, Employee>  imp
 		employeeDao.updateUserDemissionDate(levelUserId);
 		//冻结用户
 		employeeDao.updateUserLock(levelUserId,1);
-		ExecutorService executor = Executors.newFixedThreadPool(5);
+		ExecutorService executor = Executors.newCachedThreadPool();
 		CompletableFuture<Boolean> refreshUserFriend = CompletableFuture.supplyAsync(()->{
 			//获取用户担任教务老师、维修技师的所有乐团列表
 			List<String> musicGroupIds = employeeDao.queryMusicGroupIdByUserId(levelUserId);
@@ -414,7 +414,7 @@ public class EmployeeServiceImpl extends BaseServiceImpl<Integer, Employee>  imp
 			List<String> practiceGroupIds = employeeDao.queryPracticeGroupIdByUserId(levelUserId);
 			//获取用户担任教务老师的所有VIP课列表
 			List<String> vipGroupIds = employeeDao.queryVipGroupIdByUserId(levelUserId);
-			Boolean refreshFlag = false;
+			boolean refreshFlag = false;
 			if(musicGroupIds.size() > 0){
 				for (String musicGroupId : musicGroupIds) {
 					imUserFriendService.refreshGroupImUserFriend(musicGroupId, GroupType.MUSIC);