src/org/objectweb/cjdbc/controller/loadbalancer/tasks/AbstractTask.java

説明を見る。

package org.objectweb.cjdbc.controller.loadbalancer.tasks;

import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;

import org.objectweb.cjdbc.controller.loadbalancer.BackendWorkerThread;

public abstract class AbstractTask
{
  //
  // How the code is organized ?
  // 1. Member variables
  // 2. Constructor(s)
  // 3. Task management
  // 4. Getter/Setter
  //

  private int       totalNb;

  private int       nbToComplete;

  private int       success    = 0;
  private int       failed     = 0;
  private ArrayList exceptions = null;

  // Internal tid flag used by BackendWorkerThread
  private boolean   hasTid     = false;

  private ResultSet generatedKeysResultSet;

  /*
   * Constructor
   */

  public AbstractTask(int nbToComplete, int totalNb)
  {
    this.nbToComplete = nbToComplete;
    this.totalNb = totalNb;
    success = 0;
    failed = 0;
  }

  /*
   * Task management
   */

  public abstract void execute(BackendWorkerThread backendThread)
      throws SQLException;

  public synchronized void notifySuccess()

  {
    success++;

    // Notify if needed
    if ((success == nbToComplete) || (success + failed == totalNb))
    {
      if (failed > 0)
        notifyAll(); // Notify all failed threads too
      else
        notify();
    }
  }

  public synchronized void notifyCompletion()
  {
    totalNb--;
    // Notify if needed
    if (success + failed == totalNb)
    {
      notifyAll(); // Notify all failed threads
    }
  }

  public synchronized boolean notifyFailure(BackendWorkerThread backendThread,
      long timeout, Exception e) throws SQLException
  {
    failed++;

    // Log the exception
    if (exceptions == null)
      exceptions = new ArrayList();
    exceptions.add(new SQLException("BackendThread "
        + backendThread.getBackend().getName() + " failed (" + e + ")"));

    // Notify if needed
    if (success + failed == totalNb)
    {
      notifyAll(); // Notify all failed threads
    }
    else
    {
      try
      { // Wait to check if all other threads failed or not
        wait(timeout);
      }
      catch (InterruptedException ie)
      {
        throw new SQLException("Wait interrupted() in failed task of backend "
            + backendThread.getBackend().getName() + " (" + e + ")");
      }
    }
    return success > 0;
  }

  //
  // Getter/Setter
  //

  public ArrayList getExceptions()
  {
    return exceptions;
  }

  public int getFailed()
  {
    return failed;
  }

  public int getNbToComplete()
  {
    return nbToComplete;
  }

  public int getSuccess()
  {
    return success;
  }

  public int getTotalNb()
  {
    return totalNb;
  }

  public void setTotalNb(int totalNb)
  {
    this.totalNb = totalNb;
  }

  public boolean hasTid()
  {
    return hasTid;
  }

  public void setHasTid(boolean hasTid)
  {
    this.hasTid = hasTid;
  }

  public ResultSet getGeneratedKeysResultSet()
  {
    return generatedKeysResultSet;
  }

  public void setGeneratedKeysResultSet(ResultSet generatedKeysResultSet)
  {
    this.generatedKeysResultSet = generatedKeysResultSet;
  }
}

---