Apache
/
lucene
mirror of https://github.com/apache/lucene.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

LUCENE-3653: Remove extra useless thread in weak CHM test 

git-svn-id: https://svn.apache.org/repos/asf/lucene/dev/trunk@1220705 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Uwe Schindler 2011-12-19 12:14:50 +00:00
parent a6702464b3
commit baefbd33ba
1 changed files with 1 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
lucene/src/test/org/apache/lucene/util/TestWeakIdentityMap.java
View File

@ -19,7 +19,6 @@ package org.apache.lucene.util;
import java.util.Map;
import java.util.Random;
import java.util.concurrent.atomic.AtomicInteger;
import java.util.concurrent.atomic.AtomicReferenceArray;
import java.util.concurrent.Executors;
import java.util.concurrent.ExecutorService;
@ -115,7 +114,7 @@ public class TestWeakIdentityMap extends LuceneTestCase {
public void testConcurrentHashMap() throws Exception {
final int threadCount = atLeast(32), keyCount = atLeast(1024);
final ExecutorService exec = Executors.newFixedThreadPool(threadCount + 1);
final ExecutorService exec = Executors.newFixedThreadPool(threadCount);
final WeakIdentityMap<Object,Integer> map =
WeakIdentityMap.newConcurrentHashMap();
// we keep strong references to the keys,
@ -126,7 +125,6 @@ public class TestWeakIdentityMap extends LuceneTestCase {
}
try {
final AtomicInteger running = new AtomicInteger(threadCount);
for (int t = 0; t < threadCount; t++) {
final Random rnd = new Random(random.nextLong());
final int count = atLeast(rnd, 20000);
@ -155,20 +153,9 @@ public class TestWeakIdentityMap extends LuceneTestCase {
fail("Should not get here.");
}
}
running.decrementAndGet();
}
});
}
exec.execute(new Runnable() {
public void run() {
// check that GC does not cause problems in reap() method:
while (running.get() > 0) {
System.runFinalization();
System.gc();
map.isEmpty(); // simple access
}
}
});
} finally {
exec.shutdown();
while (!exec.awaitTermination(1000L, TimeUnit.MILLISECONDS));