bloritsch 2003/01/27 13:10:11
Modified: event/src/java/org/apache/excalibur/event/command
TPSPThreadManager.java
Removed: event/src/test/org/apache/excalibur/event/command/test
EventThreadPoolTestCase.java
Log:
final preparation before release of Event 1.0.2
Revision Changes Path
1.20 +5 -15
jakarta-avalon-excalibur/event/src/java/org/apache/excalibur/event/command/TPSPThreadManager.java
Index: TPSPThreadManager.java
===================================================================
RCS file:
/home/cvs/jakarta-avalon-excalibur/event/src/java/org/apache/excalibur/event/command/TPSPThreadManager.java,v
retrieving revision 1.19
retrieving revision 1.20
diff -u -r1.19 -r1.20
--- TPSPThreadManager.java 27 Jan 2003 21:00:34 -0000 1.19
+++ TPSPThreadManager.java 27 Jan 2003 21:10:11 -0000 1.20
@@ -54,8 +54,6 @@
import org.apache.commons.collections.StaticBucketMap;
import org.apache.excalibur.event.EventHandler;
import org.apache.excalibur.event.Source;
-import org.apache.excalibur.thread.ThreadControl;
-import org.apache.excalibur.thread.ThreadPool;
/**
* This is a <code>ThreadManager</code> which provides a threadpool per
@@ -67,7 +65,6 @@
*/
public final class TPSPThreadManager implements Runnable, ThreadManager
{
- private final ThreadPool m_threadPool;
private final StaticBucketMap m_pipelines = new StaticBucketMap();
private volatile boolean m_done = false;
private final long m_sleepTime;
@@ -152,20 +149,13 @@
{
while( !m_done )
{
- try
- {
- Iterator i = m_pipelines.values().iterator();
+ Iterator i = m_pipelines.values().iterator();
- while( i.hasNext() )
- {
- Thread runner = new Thread( (PipelineRunner)i.next() );
- runner.setDaemon(true);
- runner.start();
- }
- }
- catch( InterruptedException ie )
+ while( i.hasNext() )
{
- // ignore for now
+ Thread runner = new Thread( (PipelineRunner)i.next() );
+ runner.setDaemon(true);
+ runner.start();
}
if (! m_done)
--
To unsubscribe, e-mail: <mailto:[EMAIL PROTECTED]>
For additional commands, e-mail: <mailto:[EMAIL PROTECTED]>
