cocoon-cvs mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From giac...@apache.org
Subject svn commit: rev 56849 - cocoon/trunk/src/java/org/apache/cocoon/transformation/helpers
Date Sun, 07 Nov 2004 14:11:01 GMT
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;
     }
     

Mime
View raw message