eclipse-sailing-analytics/sailing-analytics
1
0 Fork 0
mirror of https://github.com/eclipse-sailing-analytics/sailing-analytics.git synced 2026-10-17 01:31:01 +00:00
Code Activity

introduced follow-up tasks; wait until executor has finished executing all tasks

Browse Source 
Change-Id: Ibb1ab9eb8e5dcf1b9cd4acc60bff520931f58c6a
This commit is contained in:
Axel Uhl committed 2016-08-12 13:19:00 +02:00
1 parent d6ca42becd
commit 9abc5d265b
1 file changed
+25 -12
Download Patch File Download Diff File Expand all files Collapse all files
java/com.sap.sailing.domain.test/src/com/sap/sailing/domain/common/test/OutperformingTheGarbageCollectorTest.java
+25 -12
View File
@@ -1,46 +1,59 @@
package com.sap.sailing.domain.common.test;
import java.util.HashMap;
import java.util.Iterator;
import java.util.Map.Entry;
import java.util.NoSuchElementException;
import java.util.Random;
import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.Executor;
import java.util.concurrent.LinkedBlockingQueue;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;
import java.util.logging.Level;
import java.util.logging.Logger;
import org.junit.Test;
public class OutperformingTheGarbageCollectorTest {
private static final Logger logger = Logger.getLogger(OutperformingTheGarbageCollectorTest.class.getName());
private static final int MAX_THREADPOOL_SIZE = 300;
private static final int NUMBER_OF_OBJECTS_TO_CREATE = 50000000;
private static final int MAX_THREADPOOL_SIZE = 50;
private static final int NUMBER_OF_OBJECTS_TO_CREATE_INITIALLY = 50000000;
private static final int NUMBER_OF_FOLLOW_UP_TASKS_TO_CREATE = 1000000000;
private final Random random = new Random();
private final Executor executor = new ThreadPoolExecutor(MAX_THREADPOOL_SIZE, MAX_THREADPOOL_SIZE, 1, TimeUnit.SECONDS, new LinkedBlockingQueue<Runnable>());
private final ConcurrentHashMap<Integer, String> mapTemporarilyHoldingGarbage = new ConcurrentHashMap<>();
private final ThreadPoolExecutor executor = new ThreadPoolExecutor(MAX_THREADPOOL_SIZE, MAX_THREADPOOL_SIZE, 1, TimeUnit.SECONDS, new LinkedBlockingQueue<Runnable>());
private final ThreadLocal<HashMap<Integer, String>> mapTemporarilyHoldingGarbage = ThreadLocal.withInitial(HashMap::new);
private int numberOfFollowUpTasksCreated;
@Test
public void testOutperformingTheGarbageCollector() throws InterruptedException {
for (int i=0; i<NUMBER_OF_OBJECTS_TO_CREATE; i++) {
for (int i=0; i<NUMBER_OF_OBJECTS_TO_CREATE_INITIALLY; i++) {
executor.execute(()->produceSomeContentAndRemoveSomeOtherContent());
}
logger.info("Done with producing tasks");
logger.info("Done with producing tasks; waiting for task queue to become empty.");
while (!executor.getQueue().isEmpty()) {
logger.info("Queue still has "+executor.getQueue().size()+" elements; still "+
numberOfFollowUpTasksCreated+" follow-up tasks to produce; waiting...");
Thread.sleep(1000);
}
logger.info("Task queue empty; terminating");
}
private void produceSomeContentAndRemoveSomeOtherContent() {
mapTemporarilyHoldingGarbage.put(random.nextInt(Integer.MAX_VALUE), ""+random.nextDouble());
final Iterator<Entry<Integer, String>> i = mapTemporarilyHoldingGarbage.entrySet().iterator();
mapTemporarilyHoldingGarbage.get().put(random.nextInt(Integer.MAX_VALUE), ""+random.nextDouble());
final Iterator<Entry<Integer, String>> i = mapTemporarilyHoldingGarbage.get().entrySet().iterator();
try {
if (i.hasNext()) {
i.next();
i.remove();
final Entry<Integer, String> entry = i.next();
mapTemporarilyHoldingGarbage.get().remove(entry.getKey());
} else {
logger.info("Strange; the collection is empty although we just added an element; welcome to concurrency...");
}
} catch (NoSuchElementException e) {
// ignore because some other thread may already have removed the last element, and that's OK then
logger.log(Level.INFO, "Very strange", e);
}
if (numberOfFollowUpTasksCreated < NUMBER_OF_FOLLOW_UP_TASKS_TO_CREATE) {
numberOfFollowUpTasksCreated++;
executor.execute(()->produceSomeContentAndRemoveSomeOtherContent());
}
}
}