[jboss-cvs] JBossCache/tests/stress/org/jboss/cache/optimistic ...

[Manik Surtani]

  User: msurtani
  Date: 07/01/30 21:40:24

  Modified:    tests/stress/org/jboss/cache/optimistic 
                        OptimisticDeadlockTest.java
  Log:
  Removed dependency on concurrent.jar
  
  Revision  Changes    Path
  1.7       +5 -4      JBossCache/tests/stress/org/jboss/cache/optimistic/OptimisticDeadlockTest.java
  
  (In the diff below, changes in quantity of whitespace are not shown.)
  
  Index: OptimisticDeadlockTest.java
  ===================================================================
  RCS file: /cvsroot/jboss/JBossCache/tests/stress/org/jboss/cache/optimistic/OptimisticDeadlockTest.java,v
  retrieving revision 1.6
  retrieving revision 1.7
  diff -u -b -r1.6 -r1.7
  --- OptimisticDeadlockTest.java	30 Dec 2006 17:49:58 -0000	1.6
  +++ OptimisticDeadlockTest.java	31 Jan 2007 02:40:24 -0000	1.7
  @@ -6,13 +6,13 @@
    */
   package org.jboss.cache.optimistic;
   
  -import EDU.oswego.cs.dl.util.concurrent.Latch;
   import org.jboss.cache.CacheImpl;
   import org.jboss.cache.Fqn;
   
   import javax.transaction.TransactionManager;
   import java.util.ArrayList;
   import java.util.List;
  +import java.util.concurrent.CountDownLatch;
   
   /**
    * @author <a href="mailto:manik at jboss.org">Manik Surtani (manik at jboss.org)</a>
  @@ -22,7 +22,8 @@
      private static final int NUM_THREADS = 10;
      private static final int NUM_LOOPS = 10;
      private static final Fqn FQN = Fqn.fromString("/test");
  -   private static final Latch latch = new Latch();
  +   private static final CountDownLatch latch = new CountDownLatch(1);
  +   
   
      public OptimisticDeadlockTest(String name)
      {
  @@ -43,7 +44,7 @@
         }
   
         cache.put(FQN, "key", "value");
  -      latch.release();
  +      latch.countDown();
   
         for (int i = 0; i < NUM_THREADS; i++)
            processors[i].join();
  @@ -71,7 +72,7 @@
            TransactionManager txman = cache.getTransactionManager();
            try
            {
  -            latch.acquire();
  +            latch.await();
            }
            catch (InterruptedException e)
            {