tomcat-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From cos...@apache.org
Subject cvs commit: jakarta-tomcat-connectors/util/java/org/apache/tomcat/util/threads ThreadPoolMX.java
Date Thu, 03 Apr 2003 00:52:26 GMT
costin      2003/04/02 16:52:26

  Modified:    util/java/org/apache/tomcat/util/threads ThreadPoolMX.java
  Log:
  All code moved to parent - but we need to keep this around for
  backward compat.
  
  Revision  Changes    Path
  1.6       +8 -115    jakarta-tomcat-connectors/util/java/org/apache/tomcat/util/threads/ThreadPoolMX.java
  
  Index: ThreadPoolMX.java
  ===================================================================
  RCS file: /home/cvs/jakarta-tomcat-connectors/util/java/org/apache/tomcat/util/threads/ThreadPoolMX.java,v
  retrieving revision 1.5
  retrieving revision 1.6
  diff -u -r1.5 -r1.6
  --- ThreadPoolMX.java	25 Mar 2003 17:53:27 -0000	1.5
  +++ ThreadPoolMX.java	3 Apr 2003 00:52:26 -0000	1.6
  @@ -65,129 +65,22 @@
   import org.apache.commons.logging.LogFactory;
   
   /**
  - * Manageable thread pool
  - *
  + * Manageable thread pool. 
  + * 
    * @author Costin Manolache
  + * @deprecated This was an attempt to introduce a JMX dependency. A better solution
  + * was the ThreadPoolListener - which is more powerfull and provides the same
  + * features. The class is here for backward compatibility, all the methods are in
  + * super().  
    */
   public class ThreadPoolMX extends ThreadPool {
       static Log log = LogFactory.getLog(ThreadPoolMX.class);
  -    protected String domain;
  +    protected String domain; // not used 
   
  -    protected String name;
  +    protected String name; // not used
   
       public ThreadPoolMX() {
           super();
       }
   
  -    public synchronized void start() {
  -        super.start();
  -    }
  -
  -    public void addThread( Thread t, ControlRunnable cr ) {
  -        threads.put( t, cr );
  -        for( int i=0; i<listeners.size(); i++ ) {
  -            ThreadPoolListener tpl=(ThreadPoolListener)listeners.elementAt(i);
  -            tpl.threadStart(this, t);
  -        }
  -    }
  -
  -    public void removeThread( Thread t ) {
  -        threads.remove(t);
  -        for( int i=0; i<listeners.size(); i++ ) {
  -            ThreadPoolListener tpl=(ThreadPoolListener)listeners.elementAt(i);
  -            tpl.threadEnd(this, t);
  -        }
  -    }
  -
  -    public void addThreadPoolListener( ThreadPoolListener tpl ) {
  -        listeners.addElement( tpl );
  -    }
  -
  -    /**
  -     * Executes a given Runnable on a thread in the pool, block if needed.
  -     */
  -    public void runIt(ThreadPoolRunnable r) {
  -        super.runIt( r );
  -    }
  -
  -    /**
  -     * Stop the thread pool
  -     */
  -    public synchronized void shutdown() {
  -        super.shutdown();
  -    }
  -
  -    /**
  -     * Returns the thread to the pool.
  -     * Called by threads as they are becoming idel.
  -     */
  -    protected synchronized void returnController(ControlRunnable c) {
  -        super.returnController(c);
  -    }
  -
  -    /**
  -     * Inform the pool that the specific thread finish.
  -     *
  -     * Called by the ControlRunnable.run() when the runnable
  -     * throws an exception.
  -     */
  -    protected synchronized void notifyThreadEnd(ControlRunnable c) {
  -        super.notifyThreadEnd(c);
  -    }
  -
  -    /** Debug display of the stage of each thread. The return is html style,
  -     * for display in the console ( it can be easily parsed too )
  -     *
  -     * @return
  -     */
  -    public String threadStatusString() {
  -        StringBuffer sb=new StringBuffer();
  -        Iterator it=threads.keySet().iterator();
  -        sb.append("<ul>");
  -        while( it.hasNext()) {
  -            sb.append("<li>");
  -            ThreadWithAttributes twa=(ThreadWithAttributes)
  -                    it.next();
  -            sb.append(twa.getCurrentStage(this) ).append(" ");
  -            sb.append( twa.getParam(this));
  -            sb.append( "</li>\n");
  -        }
  -        sb.append("</ul>");
  -        return sb.toString();
  -    }
  -
  -    /** Return an array with the status of each thread. The status
  -     * indicates the current request processing stage ( for tomcat ) or
  -     * whatever the thread is doing ( if the application using TP provide
  -     * this info )
  -     *
  -     * @return
  -     */
  -    public String[] getThreadStatus() {
  -        String status[]=new String[ threads.size()];
  -        Iterator it=threads.keySet().iterator();
  -        for( int i=0; ( i<status.length && it.hasNext()); i++ ) {
  -            ThreadWithAttributes twa=(ThreadWithAttributes)
  -                    it.next();
  -            status[i]=twa.getCurrentStage(this);
  -        }
  -        return status;
  -    }
  -
  -    /** Return an array with the current "param" ( XXX better name ? )
  -     * of each thread. This is typically the last request.
  -     *
  -     * @return
  -     */
  -    public String[] getThreadParam() {
  -        String status[]=new String[ threads.size()];
  -        Iterator it=threads.keySet().iterator();
  -        for( int i=0; ( i<status.length && it.hasNext()); i++ ) {
  -            ThreadWithAttributes twa=(ThreadWithAttributes)
  -                    it.next();
  -            Object o=twa.getParam(this);
  -            status[i]=(o==null)? null : o.toString();
  -        }
  -        return status;
  -    }
   }
  
  
  

---------------------------------------------------------------------
To unsubscribe, e-mail: tomcat-dev-unsubscribe@jakarta.apache.org
For additional commands, e-mail: tomcat-dev-help@jakarta.apache.org


Mime
View raw message