svn commit: rev 56849 - cocoon/trunk/src/java/org/apache/cocoon/transformation/helpers

[giacomo]

Author: giacomo
Date: Sun Nov  7 06:11:00 2004
New Revision: 56849

Modified:
   
cocoon/trunk/src/java/org/apache/cocoon/transformation/helpers/DefaultIncludeCacheManager.java
Log:
migrated to the RunnableManager package

Modified: 
cocoon/trunk/src/java/org/apache/cocoon/transformation/helpers/DefaultIncludeCacheManager.java
==============================================================================
--- 
cocoon/trunk/src/java/org/apache/cocoon/transformation/helpers/DefaultIncludeCacheManager.java
      (original)
+++ 
cocoon/trunk/src/java/org/apache/cocoon/transformation/helpers/DefaultIncludeCacheManager.java
      Sun Nov  7 06:11:00 2004
@@ -33,6 +33,7 @@
 import org.apache.cocoon.components.sax.XMLSerializer;
 import org.apache.cocoon.components.sax.XMLTeePipe;
 import org.apache.cocoon.components.source.SourceUtil;
+import org.apache.cocoon.components.thread.RunnableManager;
 import org.apache.cocoon.xml.XMLConsumer;
 import org.apache.excalibur.source.Source;
 import org.apache.excalibur.source.SourceException;
@@ -106,10 +107,17 @@
                     if (this.getLogger().isDebugEnabled()) {
                         this.getLogger().debug("Booting preemptive loader: " + 
this.preemptiveLoaderURI);
                     }
-                    PreemptiveBooter thread = new PreemptiveBooter();
-                    thread.setURI(this.preemptiveLoaderURI);
-                    thread.start();
-                    Thread.yield();
+                    PreemptiveBooter thread = new PreemptiveBooter( 
this.preemptiveLoaderURI );
+                    try
+                    {
+                        final RunnableManager runnableManager = 
(RunnableManager)this.manager.lookup( RunnableManager.ROLE );
+                        runnableManager.execute( thread );
+                        this.manager.release( runnableManager );
+                    }
+                    catch( final ServiceException se )
+                    {
+                        getLogger().error( "Cannot lookup RunnableManager", se 
);
+                    }
                 }
             }
         } 
@@ -446,11 +454,12 @@
     
 }
 
-final class PreemptiveBooter extends Thread {
+final class PreemptiveBooter implements Runnable {
 
-    private String uri;
-    
-    void setURI(String uri) {
+    private final String uri;
+
+    public PreemptiveBooter( final String uri )
+    {
         this.uri = uri;
     }