fix : modify code format(#725)

pull/762/head
pizihao 3 years ago
parent e276251a72
commit 529c45db77

@ -19,7 +19,6 @@ package cn.hippo4j.adapter.hystrix;
import cn.hippo4j.common.design.builder.ThreadFactoryBuilder; import cn.hippo4j.common.design.builder.ThreadFactoryBuilder;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import cn.hippo4j.core.executor.support.ThreadFactoryBuilder;
import java.util.concurrent.ScheduledExecutorService; import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.ScheduledThreadPoolExecutor; import java.util.concurrent.ScheduledThreadPoolExecutor;

@ -18,6 +18,7 @@
package cn.hippo4j.common.toolkit; package cn.hippo4j.common.toolkit;
import java.util.*; import java.util.*;
import java.util.stream.Collectors;
/** /**
* Collection util. * Collection util.

@ -24,7 +24,6 @@ import cn.hippo4j.message.enums.NotifyTypeEnum;
import cn.hippo4j.message.request.AlarmNotifyRequest; import cn.hippo4j.message.request.AlarmNotifyRequest;
import cn.hippo4j.message.request.ChangeParameterNotifyRequest; import cn.hippo4j.message.request.ChangeParameterNotifyRequest;
import cn.hippo4j.message.service.SendMessageHandler; import cn.hippo4j.message.service.SendMessageHandler;
import com.google.common.base.Joiner;
import java.time.LocalDateTime; import java.time.LocalDateTime;
import java.time.format.DateTimeFormatter; import java.time.format.DateTimeFormatter;

@ -77,7 +77,7 @@ public class AlarmControlHandler {
* @param interval * @param interval
*/ */
public void initCacheAndLock(String threadPoolId, String platform, Integer interval) { public void initCacheAndLock(String threadPoolId, String platform, Integer interval) {
String threadPoolKey = StrUtil.builder(threadPoolId, Constants.GROUP_KEY_DELIMITER, platform).toString(); String threadPoolKey = threadPoolId + Constants.GROUP_KEY_DELIMITER + platform;
Cache<String, String> cache = Caffeine.newBuilder() Cache<String, String> cache = Caffeine.newBuilder()
.expireAfterWrite(interval, TimeUnit.MINUTES) .expireAfterWrite(interval, TimeUnit.MINUTES)
.build(); .build();

Loading…
Cancel
Save