geronimo-scm mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From a..@apache.org
Subject cvs commit: incubator-geronimo/modules/system/src/java/org/apache/geronimo/system ThreadPool.java
Date Wed, 10 Mar 2004 01:06:05 GMT
adc         2004/03/09 17:06:05

  Modified:    modules/system/src/java/org/apache/geronimo/system
                        ThreadPool.java
  Log:
  Draining doesn't seem to work.
  
  Revision  Changes    Path
  1.3       +2 -13     incubator-geronimo/modules/system/src/java/org/apache/geronimo/system/ThreadPool.java
  
  Index: ThreadPool.java
  ===================================================================
  RCS file: /home/cvs/incubator-geronimo/modules/system/src/java/org/apache/geronimo/system/ThreadPool.java,v
  retrieving revision 1.2
  retrieving revision 1.3
  diff -u -r1.2 -r1.3
  --- ThreadPool.java	25 Feb 2004 09:58:14 -0000	1.2
  +++ ThreadPool.java	10 Mar 2004 01:06:05 -0000	1.3
  @@ -41,19 +41,10 @@
       private long keepAliveTime;
       private int minimumPoolSize;
       private int maximumPoolSize;
  -    private long maxDrainTime;
       private String poolName;
   
       private int nextWorkerID = 0;
   
  -    public long getMaxDrainTime() {
  -        return maxDrainTime;
  -    }
  -
  -    public void setMaxDrainTime(long maxDrainTime) {
  -        this.maxDrainTime = maxDrainTime;
  -    }
  -
       public Executor getWorkManager() {
           return workManager;
       }
  @@ -114,8 +105,7 @@
       }
   
       public void doStop() throws WaitingException, Exception {
  -        workManager.shutdownAfterProcessingCurrentlyQueuedTasks();
  -        workManager.awaitTerminationAfterShutdown(maxDrainTime);
  +        workManager.shutdownNow();
           log.info("Thread pool " + poolName + " stopped");
       }
   
  @@ -127,7 +117,6 @@
       static {
           GBeanInfoFactory infoFactory = new GBeanInfoFactory(ThreadPool.class.getName());
   
  -        infoFactory.addAttribute("maxDrainTime", true);
           infoFactory.addAttribute("keepAliveTime", true);
           infoFactory.addAttribute("minimumPoolSize", true);
           infoFactory.addAttribute("maximumPoolSize", true);
  
  
  

Mime
View raw message