|
|
@ -18,7 +18,6 @@
|
|
|
|
package cn.hippo4j.springboot.starter.core;
|
|
|
|
package cn.hippo4j.springboot.starter.core;
|
|
|
|
|
|
|
|
|
|
|
|
import cn.hippo4j.common.model.ThreadPoolParameterInfo;
|
|
|
|
import cn.hippo4j.common.model.ThreadPoolParameterInfo;
|
|
|
|
import cn.hippo4j.common.toolkit.CollectionUtil;
|
|
|
|
|
|
|
|
import cn.hippo4j.common.toolkit.ContentUtil;
|
|
|
|
import cn.hippo4j.common.toolkit.ContentUtil;
|
|
|
|
import cn.hippo4j.common.toolkit.GroupKey;
|
|
|
|
import cn.hippo4j.common.toolkit.GroupKey;
|
|
|
|
import cn.hippo4j.common.toolkit.IdUtil;
|
|
|
|
import cn.hippo4j.common.toolkit.IdUtil;
|
|
|
@ -103,21 +102,21 @@ public class ClientWorker {
|
|
|
|
|
|
|
|
|
|
|
|
class LongPollingRunnable implements Runnable {
|
|
|
|
class LongPollingRunnable implements Runnable {
|
|
|
|
|
|
|
|
|
|
|
|
private boolean flag;
|
|
|
|
private boolean cacheMapInitEmptyFlag;
|
|
|
|
|
|
|
|
|
|
|
|
private final CountDownLatch cacheCondition;
|
|
|
|
private final CountDownLatch cacheCondition;
|
|
|
|
|
|
|
|
|
|
|
|
public LongPollingRunnable(boolean flag, CountDownLatch cacheCondition) {
|
|
|
|
public LongPollingRunnable(boolean cacheMapInitEmptyFlag, CountDownLatch cacheCondition) {
|
|
|
|
this.flag = flag;
|
|
|
|
this.cacheMapInitEmptyFlag = cacheMapInitEmptyFlag;
|
|
|
|
this.cacheCondition = cacheCondition;
|
|
|
|
this.cacheCondition = cacheCondition;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
@Override
|
|
|
|
@Override
|
|
|
|
@SneakyThrows
|
|
|
|
@SneakyThrows
|
|
|
|
public void run() {
|
|
|
|
public void run() {
|
|
|
|
if (flag) {
|
|
|
|
if (cacheMapInitEmptyFlag) {
|
|
|
|
cacheCondition.await();
|
|
|
|
cacheCondition.await();
|
|
|
|
flag = false;
|
|
|
|
cacheMapInitEmptyFlag = false;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
serverHealthCheck.isHealthStatus();
|
|
|
|
serverHealthCheck.isHealthStatus();
|
|
|
|
List<CacheData> cacheDataList = new ArrayList();
|
|
|
|
List<CacheData> cacheDataList = new ArrayList();
|
|
|
|