src/org/objectweb/cjdbc/controller/core/shutdown/ShutdownThread.java

説明を見る。

package org.objectweb.cjdbc.controller.core.shutdown;

import java.util.Date;

import org.objectweb.cjdbc.common.exceptions.ShutdownException;
import org.objectweb.cjdbc.common.i18n.Translate;
import org.objectweb.cjdbc.common.log.Trace;
import org.objectweb.cjdbc.common.util.Constants;

public abstract class ShutdownThread implements Runnable
{
  public static final String CONTROLLER = "controller";
  public static final String DATABASE   = "database";
  public static final String BACKEND    = "backend";

  public ThreadGroup shutdownGroup = new ThreadGroup("shutdown"+new Date());
  
  
  protected int              shutdownLevel;

  Trace                      logger     = Trace
                                            .getLogger("org.objectweb.cjdbc.controller.shutdown");

  protected String           type;
  protected String           name;

  public ShutdownThread(int level, String type, String name)
  {
    this.shutdownLevel = level;
    this.type = type;
    this.name = name;
    logger = Trace.getLogger("org.objectweb.cjdbc.controller.shutdown." + type);
    switch (level)
    {
      case Constants.CONTROLLER_SHUTDOWN_SMART :
        logger.warn(Translate.get("controller.shutdown.type.smart",
            new String[]{name, type}));
        break;
      case Constants.CONTROLLER_SHUTDOWN_FAST :
        logger.warn(Translate.get("controller.shutdown.type.fast",
            new String[]{name, type}));
        break;
      case Constants.CONTROLLER_SHUTDOWN_IMMEDIATE :
        logger.warn(Translate.get("controller.shutdown.type.immediate",
            new String[]{name, type}));
        break;
      default :
        logger.error(Translate.get("controller.shutdown.unknown.level",level));
    }
  }

  public void run()
  {
    logger.info("Running shutdown type:"+type);
    try
    {
      beforeShutdown();
      switch (shutdownLevel)
      {
        case Constants.CONTROLLER_SHUTDOWN_SMART :
          shutdownSmart();
          break;
        case Constants.CONTROLLER_SHUTDOWN_FAST :
          shutdownFast();
          break;
        case Constants.CONTROLLER_SHUTDOWN_IMMEDIATE :
          shutdownImmediate();
          break;
        default :
          break;
      }
      postShutdown();
    }
    catch (ShutdownException se)
    {
      se.printStackTrace();
      abortShutdown(se);
    }
  }

  protected void beforeShutdown()
  {
  
  }

  protected void postShutdown()
  {

  }

  public String getShutdownType()
  {
    return this.type;
  }

  public int getShutdownLevel()
  {
    return this.shutdownLevel;
  }

  public void abortShutdown(Exception cause)
  {
    logger.info(Translate.get("controller.shutdown.aborted", cause));
  }

  public abstract void shutdownSmart() throws ShutdownException;

  public abstract void shutdownFast() throws ShutdownException;

  public abstract void shutdownImmediate() throws ShutdownException;
  
  public ThreadGroup getShutdownGroup()
  {
    return shutdownGroup;
  }
  
}

---