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(),
