fix: remove 'isContainerStarted' conditional logic.

pull/1135/head
yanrongzhen 3 years ago
parent c9ffbd8b09
commit bfbc13b973

@ -59,19 +59,6 @@ public abstract class DefaultAbstractWebThreadPoolService extends AbstractWebThr
return getWebServer().getPort(); return getWebServer().getPort();
} }
@Override
public boolean isContainerStarted() {
try {
WebServer container = getWebServer();
Field field = ReflectionUtils.findField(WebServer.class, STARTED_FIELD_NAME);
ReflectionUtils.makeAccessible(field);
return (boolean) ReflectionUtils.getField(field, container);
} catch (Throwable th) {
log.error("Failed to get isStarted flag.", th);
return false;
}
}
/** /**
* Get the thread pool object of the current web container based on the WebServer. * Get the thread pool object of the current web container based on the WebServer.
* @param webServer current Web-Server. * @param webServer current Web-Server.

@ -30,11 +30,6 @@ import java.util.concurrent.Executor;
*/ */
public interface WebThreadPoolService { public interface WebThreadPoolService {
/**
* Determine if the web container has started.
*/
boolean isContainerStarted();
/** /**
* Get web thread pool. * Get web thread pool.
* *

@ -54,16 +54,4 @@ public abstract class AbstractWebThreadPoolService1x extends AbstractWebThreadPo
return getContainer().getPort(); return getContainer().getPort();
} }
@Override
public boolean isContainerStarted() {
try {
EmbeddedServletContainer container = getContainer();
Field field = ReflectionUtils.findField(EmbeddedServletContainer.class, STARTED_FIELD_NAME);
ReflectionUtils.makeAccessible(field);
return (boolean) ReflectionUtils.getField(field, container);
} catch (Throwable th) {
log.error("Failed to get isStarted flag.", th);
return false;
}
}
} }

@ -69,8 +69,7 @@ public class WebExecutorRefreshListener extends AbstractRefreshListener<WebThrea
} }
if (!Objects.equals(beforeParameter.getCoreSize(), nowParameter.getCoreSize()) if (!Objects.equals(beforeParameter.getCoreSize(), nowParameter.getCoreSize())
|| !Objects.equals(beforeParameter.getMaxSize(), nowParameter.getMaxSize()) || !Objects.equals(beforeParameter.getMaxSize(), nowParameter.getMaxSize())
|| !Objects.equals(beforeParameter.getKeepAliveTime(), nowParameter.getKeepAliveTime()) || !Objects.equals(beforeParameter.getKeepAliveTime(), nowParameter.getKeepAliveTime())) {
|| !webThreadPoolService.isContainerStarted()) {
webThreadPoolService.updateWebThreadPool(nowParameter); webThreadPoolService.updateWebThreadPool(nowParameter);
} }
} }

Loading…
Cancel
Save