You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@sling.apache.org by cz...@apache.org on 2010/10/26 15:58:08 UTC
svn commit: r1027563 - in /sling/trunk/bundles/extensions/event/src/main:
java/org/apache/sling/event/impl/EventingThreadPool.java
resources/OSGI-INF/metatype/metatype.properties
Author: cziegeler
Date: Tue Oct 26 13:58:08 2010
New Revision: 1027563
URL: http://svn.apache.org/viewvc?rev=1027563&view=rev
Log:
It's enough to just configure the min pool size
Modified:
sling/trunk/bundles/extensions/event/src/main/java/org/apache/sling/event/impl/EventingThreadPool.java
sling/trunk/bundles/extensions/event/src/main/resources/OSGI-INF/metatype/metatype.properties
Modified: sling/trunk/bundles/extensions/event/src/main/java/org/apache/sling/event/impl/EventingThreadPool.java
URL: http://svn.apache.org/viewvc/sling/trunk/bundles/extensions/event/src/main/java/org/apache/sling/event/impl/EventingThreadPool.java?rev=1027563&r1=1027562&r2=1027563&view=diff
==============================================================================
--- sling/trunk/bundles/extensions/event/src/main/java/org/apache/sling/event/impl/EventingThreadPool.java (original)
+++ sling/trunk/bundles/extensions/event/src/main/java/org/apache/sling/event/impl/EventingThreadPool.java Tue Oct 26 13:58:08 2010
@@ -47,13 +47,10 @@ public class EventingThreadPool implemen
/** The real thread pool used. */
private org.apache.sling.commons.threads.ThreadPool threadPool;
- private static final int DEFAULT_MIN_POOL_SIZE = 35; // this is sufficient for all threads + approx 25 job queues
- private static final int DEFAULT_MAX_POOL_SIZE = 50;
+ private static final int DEFAULT_POOL_SIZE = 35;
- @Property(intValue=DEFAULT_MIN_POOL_SIZE)
- private static final String PROPERTY_MIN_POOL_SIZE = "minPoolSize";
- @Property(intValue=DEFAULT_MAX_POOL_SIZE)
- private static final String PROPERTY_MAX_POOL_SIZE = "maxPoolSize";
+ @Property(intValue=DEFAULT_POOL_SIZE)
+ private static final String PROPERTY_POOL_SIZE = "minPoolSize";
@Property(value="NORM",
options={@PropertyOption(name="NORM",value="Norm"),
@@ -67,8 +64,8 @@ public class EventingThreadPool implemen
*/
protected void activate(final ComponentContext ctx) {
final ModifiableThreadPoolConfig config = new ModifiableThreadPoolConfig();
- config.setMinPoolSize(OsgiUtil.toInteger(ctx.getProperties().get(PROPERTY_MIN_POOL_SIZE), DEFAULT_MIN_POOL_SIZE));
- config.setMaxPoolSize(OsgiUtil.toInteger(ctx.getProperties().get(PROPERTY_MAX_POOL_SIZE), DEFAULT_MAX_POOL_SIZE));
+ config.setMinPoolSize(OsgiUtil.toInteger(ctx.getProperties().get(PROPERTY_POOL_SIZE), DEFAULT_POOL_SIZE));
+ config.setMaxPoolSize(config.getMinPoolSize());
config.setQueueSize(-1); // unlimited
config.setShutdownGraceful(true);
config.setPriority(ThreadPriority.valueOf(OsgiUtil.toString(ctx.getProperties().get(PROPERTY_PRIORITY), "NORM")));
Modified: sling/trunk/bundles/extensions/event/src/main/resources/OSGI-INF/metatype/metatype.properties
URL: http://svn.apache.org/viewvc/sling/trunk/bundles/extensions/event/src/main/resources/OSGI-INF/metatype/metatype.properties?rev=1027563&r1=1027562&r2=1027563&view=diff
==============================================================================
--- sling/trunk/bundles/extensions/event/src/main/resources/OSGI-INF/metatype/metatype.properties (original)
+++ sling/trunk/bundles/extensions/event/src/main/resources/OSGI-INF/metatype/metatype.properties Tue Oct 26 13:58:08 2010
@@ -152,13 +152,9 @@ event.pool.description = This is the thr
possible to limit the maximum number of parallel processed jobs - regardless of the queue \
configuration.
-minPoolSize.name = Min Pool Size
-minPoolSize.description = The minimum pool size. The minimum pool size should be \
- higher than 10.
-
-maxPoolSize.name = Max Pool Size
-maxPoolSize.description = The maximum pool size. The maximum pool size should be higher than \
- or equal to the minimum pool size.
+minPoolSize.name = Pool Size
+minPoolSize.description = The size of the thread pool. This pool is used to execute jobs and therefore \
+ limits the maximum number of jobs executed in parallel.
priority.name = Priority
priority.description = The priority for the threads from this pool. Default is norm.