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( ); }