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 2008/12/04 14:11:27 UTC
svn commit: r723309 -
/incubator/sling/trunk/commons/threads/src/main/java/org/apache/sling/commons/threads/impl/DefaultThreadPool.java
Author: cziegeler
Date: Thu Dec 4 05:11:27 2008
New Revision: 723309
URL: http://svn.apache.org/viewvc?rev=723309&view=rev
Log:
SLING-758 : Correctly evaluate block policy and use the correct handler.
Modified:
incubator/sling/trunk/commons/threads/src/main/java/org/apache/sling/commons/threads/impl/DefaultThreadPool.java
Modified: incubator/sling/trunk/commons/threads/src/main/java/org/apache/sling/commons/threads/impl/DefaultThreadPool.java
URL: http://svn.apache.org/viewvc/incubator/sling/trunk/commons/threads/src/main/java/org/apache/sling/commons/threads/impl/DefaultThreadPool.java?rev=723309&r1=723308&r2=723309&view=diff
==============================================================================
--- incubator/sling/trunk/commons/threads/src/main/java/org/apache/sling/commons/threads/impl/DefaultThreadPool.java (original)
+++ incubator/sling/trunk/commons/threads/src/main/java/org/apache/sling/commons/threads/impl/DefaultThreadPool.java Thu Dec 4 05:11:27 2008
@@ -116,13 +116,13 @@
handler = new ThreadPoolExecutor.AbortPolicy();
break;
case DISCARD :
- handler = new ThreadPoolExecutor.AbortPolicy();
+ handler = new ThreadPoolExecutor.DiscardPolicy();
break;
case DISCARDOLDEST :
- handler = new ThreadPoolExecutor.AbortPolicy();
+ handler = new ThreadPoolExecutor.DiscardOldestPolicy();
break;
case RUN :
- handler = new ThreadPoolExecutor.AbortPolicy();
+ handler = new ThreadPoolExecutor.CallerRunsPolicy();
break;
}
this.executor = new ThreadPoolExecutor(this.configuration.getMinPoolSize(),