zhuyijun/nacos
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Fix #150

Browse Source
This commit is contained in:
nkorange 2018-10-29 21:25:53 +08:00
parent 077c4cdb6f
commit 25f219623c
3 changed files with 29 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
naming/src/main/java/com/alibaba/nacos/naming/core/DomainsManager.java
View File

@ -670,6 +670,10 @@ public class DomainsManager {
lock.unlock();
}
// clean up lock resources since they are no longer in need:
dom2LockMap.remove(dom.getName());
dom2ContionMap.remove(dom.getName());
} catch (Throwable e) {
Loggers.SRV_LOG.error("VIPSRV-DOM", "error while processing dom update", e);
}

17
naming/src/main/java/com/alibaba/nacos/naming/misc/UtilsAndCommons.java
View File

@ -29,9 +29,7 @@ import org.apache.commons.lang3.StringUtils;
import java.io.File;
import java.util.HashMap;
import java.util.Map;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.ScheduledThreadPoolExecutor;
import java.util.concurrent.ThreadFactory;
import java.util.concurrent.*;
/**
* @author nacos
@ -117,6 +115,8 @@ public class UtilsAndCommons {
public static final ScheduledExecutorService INIT_CONFIG_EXECUTOR;
public static final Executor RAFT_PUBLISH_EXECUTOR;
static {
// custom serializer and deserializer for fast-json
SerializeConfig.getGlobalInstance()
@ -181,6 +181,17 @@ public class UtilsAndCommons {
}
});
RAFT_PUBLISH_EXECUTOR
= Executors.newFixedThreadPool(Runtime.getRuntime().availableProcessors(), new ThreadFactory() {
@Override
public Thread newThread(Runnable r) {
Thread t = new Thread(r);
t.setName("nacos.naming.raft.publisher");
t.setDaemon(true);
return t;
}
});
}
public static String getAllExceptionMsg(Throwable e) {

13
naming/src/main/java/com/alibaba/nacos/naming/web/ApiCommands.java
View File

@ -553,11 +553,20 @@ public class ApiCommands {
if (virtualClusterDomain == null) {
regDom(request);
Lock lock = domainsManager.addLock(dom);
Condition condition = domainsManager.addCondtion(dom);
UtilsAndCommons.RAFT_PUBLISH_EXECUTOR.execute(new Runnable() {
@Override
public void run() {
try {
regDom(request);
} catch (Exception e) {
Loggers.SRV_LOG.error("REG-SERIVCE", "register service failed, service:" + dom, e);
}
}
});
try {
lock.lock();
condition.await(5000, TimeUnit.MILLISECONDS);