Hibernate
/
hibernate-orm
mirror of https://github.com/hibernate/hibernate-orm
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

using ConcurrentHashMap for decrease synchronization

This commit is contained in:
Nikolay Shestakov 2012-12-29 00:13:50 +06:00
parent b11c23fd45
commit 1c0b551055
1 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
hibernate-core/src/main/java/org/hibernate/context/internal/JTASessionContext.java
View File

@ -23,8 +23,9 @@
*/ */
package org.hibernate.context.internal; package org.hibernate.context.internal;
import java.util.Hashtable;
import java.util.Map; import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;
import javax.transaction.Synchronization; import javax.transaction.Synchronization;
import javax.transaction.Transaction; import javax.transaction.Transaction;
import javax.transaction.TransactionManager; import javax.transaction.TransactionManager;
@ -67,7 +68,7 @@ import org.hibernate.engine.transaction.jta.platform.spi.JtaPlatform;
public class JTASessionContext extends AbstractCurrentSessionContext { public class JTASessionContext extends AbstractCurrentSessionContext {
private static final CoreMessageLogger LOG = Logger.getMessageLogger(CoreMessageLogger.class, JTASessionContext.class.getName()); private static final CoreMessageLogger LOG = Logger.getMessageLogger(CoreMessageLogger.class, JTASessionContext.class.getName());
private transient Map currentSessionMap = new Hashtable(); private transient Map<Object, Session> currentSessionMap = new ConcurrentHashMap<Object, Session>();
public JTASessionContext(SessionFactoryImplementor factory) { public JTASessionContext(SessionFactoryImplementor factory) {
super( factory ); super( factory );
@ -103,7 +104,7 @@ public class JTASessionContext extends AbstractCurrentSessionContext {
final Object txnIdentifier = jtaPlatform.getTransactionIdentifier( txn ); final Object txnIdentifier = jtaPlatform.getTransactionIdentifier( txn );
Session currentSession = ( Session ) currentSessionMap.get( txnIdentifier ); Session currentSession = currentSessionMap.get( txnIdentifier );
if ( currentSession == null ) { if ( currentSession == null ) {
currentSession = buildOrObtainSession(); currentSession = buildOrObtainSession();