Author: stliu
Date: 2010-09-02 02:31:15 -0400 (Thu, 02 Sep 2010)
New Revision: 20306
Modified:
search/branches/v3_1_1_GA_CP/src/test/java/org/hibernate/search/test/optimizer/OptimizerTestCase.java
Log:
JBPAPP-5005 org.hibernate.search.test.optimizer.OptimizerTestCase hangs on sybase
Modified:
search/branches/v3_1_1_GA_CP/src/test/java/org/hibernate/search/test/optimizer/OptimizerTestCase.java
===================================================================
---
search/branches/v3_1_1_GA_CP/src/test/java/org/hibernate/search/test/optimizer/OptimizerTestCase.java 2010-09-02
03:08:59 UTC (rev 20305)
+++
search/branches/v3_1_1_GA_CP/src/test/java/org/hibernate/search/test/optimizer/OptimizerTestCase.java 2010-09-02
06:31:15 UTC (rev 20306)
@@ -4,6 +4,7 @@
import java.io.File;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
+import java.util.concurrent.atomic.AtomicInteger;
import org.apache.lucene.analysis.StopAnalyzer;
import org.apache.lucene.queryParser.ParseException;
@@ -54,7 +55,7 @@
es.execute( work );
es.execute( reverseWork );
}
- while ( work.count < iteration - 1 ) {
+ while ( work.count.get() < iteration - 1 ) {
Thread.sleep( 20 );
}
System.out.println( iteration + " iterations (8 tx per iteration) in " +
nThreads + " threads: " + ( System
@@ -63,7 +64,7 @@
protected static class Work implements Runnable {
private final SessionFactory sf;
- public volatile int count = 0;
+ public AtomicInteger count = new AtomicInteger(0);
public Work(SessionFactory sf) {
this.sf = sf;
@@ -121,7 +122,7 @@
s.delete( c );
tx.commit();
s.close();
- count++;
+ count.getAndIncrement();
} catch (Throwable t) {
t.printStackTrace( );
}