bloritsch 02/02/05 13:08:18
Modified: src/scratchpad/org/apache/avalon/excalibur/thread/impl
DefaultThreadPool.java
ResourceLimitingThreadPool.java
Log:
make sure all Threads are Daemon threads so that regular shutdown of JVM can
occur
Revision Changes Path
1.11 +1 -0
jakarta-avalon-excalibur/src/scratchpad/org/apache/avalon/excalibur/thread/impl/DefaultThreadPool.java
Index: DefaultThreadPool.java
===================================================================
RCS file:
/home/cvs/jakarta-avalon-excalibur/src/scratchpad/org/apache/avalon/excalibur/thread/impl/DefaultThreadPool.java,v
retrieving revision 1.10
retrieving revision 1.11
diff -u -r1.10 -r1.11
--- DefaultThreadPool.java 20 Jan 2002 04:38:14 -0000 1.10
+++ DefaultThreadPool.java 5 Feb 2002 21:08:18 -0000 1.11
@@ -80,6 +80,7 @@
{
final String name = new StringBuffer(getName()).append(" Worker
#").append(m_level++).toString();
final WorkerThread worker = new WorkerThread( this, name, m_pool,
m_context );
+ worker.setDaemon( true );
worker.enableLogging( m_logger );
worker.start();
return worker;
1.3 +5 -5
jakarta-avalon-excalibur/src/scratchpad/org/apache/avalon/excalibur/thread/impl/ResourceLimitingThreadPool.java
Index: ResourceLimitingThreadPool.java
===================================================================
RCS file:
/home/cvs/jakarta-avalon-excalibur/src/scratchpad/org/apache/avalon/excalibur/thread/impl/ResourceLimitingThreadPool.java,v
retrieving revision 1.2
retrieving revision 1.3
diff -u -r1.2 -r1.3
--- ResourceLimitingThreadPool.java 25 Jan 2002 01:24:27 -0000 1.2
+++ ResourceLimitingThreadPool.java 5 Feb 2002 21:08:18 -0000 1.3
@@ -33,7 +33,7 @@
* @author <a href="mailto:[EMAIL PROTECTED]">Leif Mortenson</a>
* @author <a href="mailto:[EMAIL PROTECTED]">Stefano Mazzocchi</a>
* @author <a href="mailto:[EMAIL PROTECTED]">Peter Donald</a>
- * @version CVS $Revision: 1.2 $ $Date: 2002/01/25 01:24:27 $
+ * @version CVS $Revision: 1.3 $ $Date: 2002/02/05 21:08:18 $
* @since 4.1
*/
public class ResourceLimitingThreadPool
@@ -146,10 +146,10 @@
*/
public Object newInstance()
{
- final String name =
+ final String name =
new StringBuffer( getName()).append( " Worker #" ).append(
m_level++ ).toString();
final WorkerThread worker = new WorkerThread( this, name, m_pool,
m_context );
-
+ worker.setDaemon( true );
worker.enableLogging( m_logger );
worker.start();
@@ -169,7 +169,7 @@
/**
* Cleans up any resources associated with the specified object and
takes it
- * out of commission.
+ * out of commission.
*
* @param object the object to be decommissioned
*
@@ -248,7 +248,7 @@
*
* @return the worker thread retrieved from pool
*
- * @todo remove the line:
+ * @todo remove the line:
*
<code>worker.setContextClassLoader(Thread.currentThread().getContextClassLoader());</code>
*/
protected WorkerThread getWorker()
--
To unsubscribe, e-mail: <mailto:[EMAIL PROTECTED]>
For additional commands, e-mail: <mailto:[EMAIL PROTECTED]>
