CVS update: JGroups/src/org/jgroups/protocols BARRIER.java

  User: belaban 
  Date: 10/09/17 11:51:13

  Modified:    src/org/jgroups/protocols BARRIER.java
  Log:
  use of Util.createConcurrentMap() instead of new ConcurrentHashMap()
  
  Revision  Changes    Path
  1.19      +4 -4      JGroups/src/org/jgroups/protocols/BARRIER.java
  
  Index: BARRIER.java
  ===================================================================
  RCS file: /cvsroot/javagroups/JGroups/src/org/jgroups/protocols/BARRIER.java,v
  retrieving revision 1.18
  retrieving revision 1.19
  diff -u -r1.18 -r1.19
  --- BARRIER.java	24 Feb 2010 11:22:45 -0000	1.18
  +++ BARRIER.java	17 Sep 2010 11:51:13 -0000	1.19
  @@ -5,11 +5,11 @@
   import org.jgroups.annotations.Property;
   import org.jgroups.stack.Protocol;
   import org.jgroups.util.TimeScheduler;
  +import org.jgroups.util.Util;
   
  -import java.util.Set;
   import java.util.HashSet;
   import java.util.Iterator;
  -import java.util.concurrent.ConcurrentHashMap;
  +import java.util.Set;
   import java.util.concurrent.ConcurrentMap;
   import java.util.concurrent.Future;
   import java.util.concurrent.TimeUnit;
  @@ -26,7 +26,7 @@
    * When an OPEN_BARRIER event is received, we simply open the barrier again and let all messages pass in the up
    * direction. This is done by releasing the WL.
    * @author Bela Ban
  - * @version $Id: BARRIER.java,v 1.18 2010/02/24 11:22:45 belaban Exp $
  + * @version $Id: BARRIER.java,v 1.19 2010/09/17 11:51:13 belaban Exp $
    */
   public class BARRIER extends Protocol {
       
  @@ -38,7 +38,7 @@
       /** signals to waiting threads that the barrier is open again */
       Condition barrier_opened=lock.newCondition();
       Condition no_msgs_pending=lock.newCondition();
  -    ConcurrentMap<Thread,Object> in_flight_threads=new ConcurrentHashMap<Thread,Object>();
  +    ConcurrentMap<Thread, Object> in_flight_threads=Util.createConcurrentMap();
       Future<?> barrier_opener_future=null;
       TimeScheduler timer;
       private static final Object NULL=new Object();
  
  
  

------------------------------------------------------------------------------
Start uncovering the many advantages of virtual appliances
and start using them to simplify application deployment and
accelerate your shift to cloud computing.
http://p.sf.net/sfu/novell-sfdev2dev