[jboss-svn-commits] JBL Code SVN: r18372 - labs/jbossrules/trunk/drools-core/src/main/java/org/drools/common.

[jboss-svn-commits at lists.jboss.org]

Author: tirelli
Date: 2008-02-07 08:31:23 -0500 (Thu, 07 Feb 2008)
New Revision: 18372

Modified:
   labs/jbossrules/trunk/drools-core/src/main/java/org/drools/common/AbstractWorkingMemory.java
Log:
JBRULES-1392: fixing concurrent access to a collections map

Modified: labs/jbossrules/trunk/drools-core/src/main/java/org/drools/common/AbstractWorkingMemory.java
===================================================================
--- labs/jbossrules/trunk/drools-core/src/main/java/org/drools/common/AbstractWorkingMemory.java	2008-02-07 13:14:54 UTC (rev 18371)
+++ labs/jbossrules/trunk/drools-core/src/main/java/org/drools/common/AbstractWorkingMemory.java	2008-02-07 13:31:23 UTC (rev 18372)
@@ -30,6 +30,7 @@
 import java.util.List;
 import java.util.Map;
 import java.util.Map.Entry;
+import java.util.concurrent.ConcurrentHashMap;
 import java.util.concurrent.locks.Lock;
 import java.util.concurrent.locks.ReentrantLock;
 
@@ -216,7 +217,7 @@
         this.processInstanceFactories.put( RuleFlowProcess.RULEFLOW_TYPE,
                                            new RuleFlowProcessInstanceFactory() );
 
-        this.typeConfMap = new HashMap<EntryPoint, Map<Object, ObjectTypeConf>>();
+        this.typeConfMap = new ConcurrentHashMap<EntryPoint, Map<Object, ObjectTypeConf>>();
     }
 
     // ------------------------------------------------------------
@@ -1633,7 +1634,7 @@
                                             Object object) {
         Map<Object, ObjectTypeConf> map = this.typeConfMap.get( entrypoint );
         if ( map == null ) {
-            map = new HashMap<Object, ObjectTypeConf>();
+            map = new ConcurrentHashMap<Object, ObjectTypeConf>();
             this.typeConfMap.put( entrypoint,
                                   map );
         }
@@ -1689,7 +1690,7 @@
                                    ObjectTypeConf conf) {
         Map<Object, ObjectTypeConf> map = this.typeConfMap.get( entryPoint );
         if ( map == null ) {
-            map = new HashMap<Object, ObjectTypeConf>();
+            map = new ConcurrentHashMap<Object, ObjectTypeConf>();
             this.typeConfMap.put( entryPoint,
                                   map );
         }