[jbosscache-commits] JBoss Cache SVN: r6173 - in core/branches/2.2.X/src/main/java/org/jboss/cache: util/concurrent and 1 other directory.
jbosscache-commits at lists.jboss.org
jbosscache-commits at lists.jboss.org
Fri Jul 4 05:38:16 EDT 2008
Author: manik.surtani at jboss.com
Date: 2008-07-04 05:38:16 -0400 (Fri, 04 Jul 2008)
New Revision: 6173
Modified:
core/branches/2.2.X/src/main/java/org/jboss/cache/lock/LockMap.java
core/branches/2.2.X/src/main/java/org/jboss/cache/util/concurrent/ConcurrentHashSet.java
Log:
JBCACHE-1383: ConcurrentHashSet should allow for setting a "concurrency level"
Modified: core/branches/2.2.X/src/main/java/org/jboss/cache/lock/LockMap.java
===================================================================
--- core/branches/2.2.X/src/main/java/org/jboss/cache/lock/LockMap.java 2008-07-04 08:57:58 UTC (rev 6172)
+++ core/branches/2.2.X/src/main/java/org/jboss/cache/lock/LockMap.java 2008-07-04 09:38:16 UTC (rev 6173)
@@ -33,7 +33,7 @@
public LockMap()
{
- this(new ConcurrentHashSet<Object>());
+ this(new ConcurrentHashSet<Object>(4));
}
/**
Modified: core/branches/2.2.X/src/main/java/org/jboss/cache/util/concurrent/ConcurrentHashSet.java
===================================================================
--- core/branches/2.2.X/src/main/java/org/jboss/cache/util/concurrent/ConcurrentHashSet.java 2008-07-04 08:57:58 UTC (rev 6172)
+++ core/branches/2.2.X/src/main/java/org/jboss/cache/util/concurrent/ConcurrentHashSet.java 2008-07-04 09:38:16 UTC (rev 6173)
@@ -24,6 +24,22 @@
map = new ConcurrentHashMap<E, Object>();
}
+ /**
+ * @param concurrency concurrency level passed in to the CHM constructor. See {@link ConcurrentHashMap#ConcurrentHashMap(int, float, int)} javadocs for details.
+ */
+ public ConcurrentHashSet(int concurrency)
+ {
+ map = new ConcurrentHashMap<E, Object>(16, 0.75f, concurrency);
+ }
+
+ /**
+ * Params passed in to the CHM constructor. See {@link ConcurrentHashMap#ConcurrentHashMap(int, float, int)} javadocs for details.
+ */
+ public ConcurrentHashSet(int initSize, float loadFactor, int concurrency)
+ {
+ map = new ConcurrentHashMap<E, Object>(initSize, loadFactor, concurrency);
+ }
+
@Override
public int size()
{
More information about the jbosscache-commits
mailing list