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

Harden TestSearchWithThreads to not fail if machine was slow (trunk) 

git-svn-id: https://svn.apache.org/repos/asf/lucene/dev/trunk@1044100 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Shai Erera 2010-12-09 19:26:02 +00:00
parent b24f2e33d7
commit cdf6350cd6
1 changed files with 10 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
lucene/src/test/org/apache/lucene/search/TestSearchWithThreads.java
View File

@ -66,11 +66,10 @@ public class TestSearchWithThreads extends LuceneTestCase {
final IndexSearcher s = new IndexSearcher(r);
final AtomicBoolean failed = new AtomicBoolean();
final long stopAt = System.currentTimeMillis() + RUN_TIME_MSEC;
final AtomicLong netSearch = new AtomicLong();
Thread[] threads = new Thread[NUM_SEARCH_THREADS];
for(int threadID=0;threadID<NUM_SEARCH_THREADS;threadID++) {
for (int threadID = 0; threadID < NUM_SEARCH_THREADS; threadID++) {
threads[threadID] = new Thread() {
TotalHitCountCollector col = new TotalHitCountCollector();
@Override
@ -78,6 +77,7 @@ public class TestSearchWithThreads extends LuceneTestCase {
try {
long totHits = 0;
long totSearch = 0;
long stopAt = System.currentTimeMillis() + RUN_TIME_MSEC;
while(System.currentTimeMillis() < stopAt && !failed.get()) {
s.search(new TermQuery(new Term("body", "aaa")), col);
totHits += col.getTotalHits();
@ -85,7 +85,7 @@ public class TestSearchWithThreads extends LuceneTestCase {
totHits += col.getTotalHits();
totSearch++;
}
assertTrue(totHits > 0);
assertTrue(totSearch > 0 && totHits > 0);
netSearch.addAndGet(totSearch);
} catch (Exception exc) {
failed.set(true);
@ -94,12 +94,16 @@ public class TestSearchWithThreads extends LuceneTestCase {
}
};
threads[threadID].setDaemon(true);
threads[threadID].start();
}
for(int threadID=0;threadID<NUM_SEARCH_THREADS;threadID++) {
threads[threadID].join();
for (Thread t : threads) {
t.start();
}
for (Thread t : threads) {
t.join();
}
if (VERBOSE) System.out.println(NUM_SEARCH_THREADS + " threads did " + netSearch.get() + " searches");
s.close();