Abstract get Web Server default method

pull/661/head
chen.ma 3 years ago
parent abf25874d8
commit e395c140a4

@ -51,15 +51,20 @@ public abstract class AbstractWebThreadPoolService implements WebThreadPoolServi
if (executor == null) {
synchronized (AbstractWebThreadPoolService.class) {
if (executor == null) {
ApplicationContext applicationContext = ApplicationContextHolder.getInstance();
WebServer webServer = ((WebServerApplicationContext) applicationContext).getWebServer();
executor = getWebThreadPoolByServer(webServer);
executor = getWebThreadPoolByServer(getWebServer());
}
}
}
return executor;
}
@Override
public WebServer getWebServer() {
ApplicationContext applicationContext = ApplicationContextHolder.getInstance();
WebServer webServer = ((WebServerApplicationContext) applicationContext).getWebServer();
return webServer;
}
@Override
public void run(ApplicationArguments args) {
try {

@ -21,6 +21,7 @@ import cn.hippo4j.common.model.ThreadPoolBaseInfo;
import cn.hippo4j.common.model.ThreadPoolParameter;
import cn.hippo4j.common.model.ThreadPoolParameterInfo;
import cn.hippo4j.common.model.ThreadPoolRunStateInfo;
import org.springframework.boot.web.server.WebServer;
import java.util.concurrent.Executor;
@ -63,4 +64,15 @@ public interface WebThreadPoolService {
* @param threadPoolParameterInfo
*/
void updateWebThreadPool(ThreadPoolParameterInfo threadPoolParameterInfo);
/**
* Get web server.
*
* @return
*/
default WebServer getWebServer() {
return null;
}
;
}

Loading…
Cancel
Save