@@ -392,7 +392,7 @@ public class ModelSetup { | |||||
if (childClassName == null) childClassName = entity.getClass().getPackage().getName() + "." + childEntityType; | if (childClassName == null) childClassName = entity.getClass().getPackage().getName() + "." + childEntityType; | ||||
final Class<? extends Identifiable> childClass = forName(childClassName); | final Class<? extends Identifiable> childClass = forName(childClassName); | ||||
@Cleanup("shutdownNow") final ExecutorService exec = fixedPool(Math.min(children.length, maxConcurrency)); | |||||
@Cleanup("shutdownNow") final ExecutorService exec = fixedPool(Math.min(children.length, maxConcurrency), "ModelSetup.exec"); | |||||
final Set<Future<?>> futures = new HashSet<>(); | final Set<Future<?>> futures = new HashSet<>(); | ||||
for (final JsonNode child : children) { | for (final JsonNode child : children) { | ||||
if (!(child instanceof ObjectNode)) { | if (!(child instanceof ObjectNode)) { | ||||
@@ -23,7 +23,7 @@ public class AnalyticsQueueService { | |||||
@Autowired private RestServerConfiguration configuration; | @Autowired private RestServerConfiguration configuration; | ||||
private final Map<String, AnalyticsData> analyticsData = new HashMap<>(); | private final Map<String, AnalyticsData> analyticsData = new HashMap<>(); | ||||
private final ExecutorService executorService = fixedPool(10); | |||||
private final ExecutorService exec = fixedPool(10, "AnalyticsQueueService.exec"); | |||||
public void report(String uuid, AnalyticsData data) { | public void report(String uuid, AnalyticsData data) { | ||||
synchronized (analyticsData) { analyticsData.put(uuid, data); } | synchronized (analyticsData) { analyticsData.put(uuid, data); } | ||||
@@ -60,7 +60,7 @@ public class AnalyticsQueueService { | |||||
analyticsData.clear(); | analyticsData.clear(); | ||||
} | } | ||||
copy.forEach((key, value) -> executorService.submit(() -> { | |||||
copy.forEach((key, value) -> exec.submit(() -> { | |||||
final HttpRequestBean request = new HttpRequestBean(POST, writeUrl, value.buildMessage()); | final HttpRequestBean request = new HttpRequestBean(POST, writeUrl, value.buildMessage()); | ||||
try { | try { | ||||
final HttpResponseBean response = HttpUtil.getResponse(request); | final HttpResponseBean response = HttpUtil.getResponse(request); | ||||
@@ -104,7 +104,7 @@ public class SqlViewSearchHelper { | |||||
} | } | ||||
final ResultSetBean rs = configuration.execSql(query, args); | final ResultSetBean rs = configuration.execSql(query, args); | ||||
final List<Future<?>> results = new ArrayList<>(rs.rowCount()); | final List<Future<?>> results = new ArrayList<>(rs.rowCount()); | ||||
final ExecutorService exec = searchByEncryptedField ? fixedPool(Math.min(16, rs.rowCount())) : null; | |||||
final ExecutorService exec = searchByEncryptedField ? fixedPool(Math.min(16, rs.rowCount()), "SqlViewSearchHelper.exec") : null; | |||||
for (Map<String, Object> row : rs.getRows()) { | for (Map<String, Object> row : rs.getRows()) { | ||||
if (searchByEncryptedField) { | if (searchByEncryptedField) { | ||||