eclipse-sailing-analytics/sailing-analytics
1
0
Fork 0
mirror of https://github.com/eclipse-sailing-analytics/sailing-analytics.git synced 2026-09-20 04:35:32 +00:00
Code Activity

Bug 5214: revert commit 7de2f14586

Browse Source
This commit is contained in:
Thomas Wiese
2020-07-31 09:21:11 +02:00
parent 16cef3fb5c
commit f48e5ca5b9
5 changed files with 28 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files
java/com.sap.sse.datamining.test/src/com/sap/sse/datamining/impl/TestAbortingHeavyLoadQuery.java
+1 -4
View File
@@ -45,7 +45,6 @@ import com.sap.sse.datamining.shared.data.QueryResultState;
import com.sap.sse.datamining.shared.impl.GenericGroupKey;
import com.sap.sse.datamining.test.util.components.StatefulBlockingInstruction;
import com.sap.sse.datamining.test.util.components.StatefulProcessorInstruction;
import com.sap.sse.util.ThreadPoolUtil;
/**
* Integration test aborting a query with simulated heavy load instructions. Uses a highly customized processor chain
@@ -250,9 +249,7 @@ public class TestAbortingHeavyLoadQuery {
if (RecordExecution) {
executionRecord = new ConcurrentLinkedQueue<>();
}
executor = ThreadPoolUtil.INSTANCE
.createBackgroundTaskThreadPoolExecutor(ExecutorPoolSize, this.getClass().getName());
executor = new DataMiningExecutorService(ExecutorPoolSize);
processors = new ArrayList<>();
unfinishedInstructions = ConcurrentHashMap.newKeySet();
java/com.sap.sse.datamining.test/src/com/sap/sse/datamining/test/util/ConcurrencyTestsUtil.java
+2 -4
View File
@@ -11,15 +11,13 @@ import java.util.Map.Entry;
import java.util.concurrent.ExecutorService;
import com.sap.sse.datamining.components.Processor;
import com.sap.sse.datamining.impl.DataMiningExecutorService;
import com.sap.sse.datamining.shared.GroupKey;
import com.sap.sse.util.ThreadPoolUtil;
public class ConcurrencyTestsUtil extends TestsUtil {
private static final int THREAD_POOL_SIZE = Math.max(Runtime.getRuntime().availableProcessors(), 3);
private static final ExecutorService executor = ThreadPoolUtil.INSTANCE
.createBackgroundTaskThreadPoolExecutor(THREAD_POOL_SIZE, ConcurrencyTestsUtil.class.getName());
private static final ExecutorService executor = new DataMiningExecutorService(THREAD_POOL_SIZE);
public static ExecutorService getSharedExecutor() {
return executor;