タスクの実装¶

package sample.mytest;

import java.util.List;
import jp.co.intra_mart.foundation.asynchronous.AbstractTask;

public class MyTask extends AbstractTask {

   private volatile boolean releaseNotified;

   public MyTask() {
      this.releaseNotified = false;
   }

   @Override
   public void run() {
      // 処理用データの取得
      List<String> list = ...;

      for (String item : list) {
         // itemに対する処理
         doSomething(item);

         // releaseが呼ばれていた場合は途中でも終了
         if (this.releaseNotified) {
            break;
         }
      }
   }

   @Override
   public void release() {
      this.releaseNotified = true;
   }

   private void doSomething(String item) {
      ...
   }
}

package sample.mytest;

import java.util.List;
import jp.co.intra_mart.foundation.asynchronous.AbstractTask;

public class MyTask2 extends AbstractTask {

   private volatile boolean releaseNotified;

   private volatile boolean finished;

   public MyTask2() {
      this.releaseNotified = false;
      this.finished = false;
   }

   @Override
   public void run() {
      try {
         // 処理用データの取得
         List<String> list = ...;

         for (String item : list) {
            // itemに対する処理
            doSomething(item);

            // releaseが呼ばれていた場合は途中でも終了
            if (this.releaseNotified) {
               break;
            }
         }
      } finally {
         this.finished = true;
      }
   }

   @Override
   public void release() {
      this.releaseNotified = true;
      while (!this.finished) {
         try {
            Thread.sleep(1000);
         } catch (InterruptedException e) {
            //
         }
      }
   }

   private void doSomething(String item) {
      ...
   }
}

package sample.mytest;

import java.util.Map;

import jp.co.intra_mart.foundation.asynchronous.AbstractTask;

public class ParameterTask extends AbstractTask {

   @Override
   public void run() {
      Map<String, ?> parameter = getParameter();
      String name = (String) parameter.get("NAME");
      int age = ((Number) parameter.get("AGE")).intValue();
      businessLogic(name, age);
   }

   private void businessLogic(String name, int age) {
      ...
   }
}

package sample.mytest;

import java.util.HashMap;
import java.util.Map;

import jp.co.intra_mart.foundation.asynchronous.TaskControlException;
import jp.co.intra_mart.foundation.asynchronous.TaskManager;

public class ParameterTaskRegister {
   ...

   private void addTask() {
      Map<String, Object> parameter = new HashMap<String, Object>();
      parameter.put("NAME", "intra-mart");
      parameter.put("AGE", 26);
      try {
         TaskManager.addParallelizedTask("sample.mytest.ParameterTask", parameter);
      } catch (TaskControlException e) {
         ...
      }
   }
   ...
}

package sample.mytest;

import jp.co.intra_mart.foundation.asynchronous.AbstractTask;
import jp.co.intra_mart.foundation.context.Contexts;
import jp.co.intra_mart.foundation.context.model.AccountContext;
import jp.co.intra_mart.foundation.context.model.UserType;

public class ContextTask extends AbstractTask {

   @Override
   public void run() {
      // 登録時の Context を利用可能
      AccountContext accountContext = Contexts.get(AccountContext.class);
      UserType userType = accountContext.getUserType();
      String userCd = accountContext.getUserCd();
      businessLogic(userCd);
   }

   private void businessLogic(String userCd) {
      ...
   }
}

package sample.mytest;

import jp.co.intra_mart.foundation.asynchronous.TaskControlException;
import jp.co.intra_mart.foundation.asynchronous.TaskManager;
import jp.co.intra_mart.foundation.context.Contexts;
import jp.co.intra_mart.foundation.context.model.AccountContext;
import jp.co.intra_mart.foundation.context.model.UserType;

public class ContextTaskRegister {

   private void addTask() {
      // Context の情報を明示的に取得や指定しなくても、
      // 現在の Context が自動的にタスクキューに登録される

      // AccountContext accountContext = Contexts.get(AccountContext.class);
      // UserType userType = accountContext.getUserType();
      // String userCd = accountContext.getUserCd();

      try {
         TaskManager.addParallelizedTask("sample.mytest.ContextTask", null);
      } catch (TaskControlException e) {
         ...
      }
   }
}

package sample.mytest;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;

import jp.co.intra_mart.foundation.asynchronous.AbstractTask;
import jp.co.intra_mart.foundation.database.DBTransaction;
import jp.co.intra_mart.foundation.database.DatabaseUtil;
import jp.co.intra_mart.foundation.database.TenantDatabase;
import jp.co.intra_mart.foundation.database.exception.DatabaseException;

public class DatabaseTask extends AbstractTask {

   @Override
   public void run() {
      DBTransaction transaction = new DBTransaction();
      boolean success = false;
      try {
         transaction.beginTransaction();
         try {
            TenantDatabase database = new TenantDatabase();
            Connection connection = database.getConnection();
            try {
               String sql = "select name, age from my_test";
               PreparedStatement statement = connection.prepareStatement(sql);
               try {
                  ResultSet resultSet = statement.executeQuery();
                  try {
                     while (resultSet.next()) {
                        String name = resultSet.getString("name");
                        int age = resultSet.getInt("age");
                        businessLogic(name, age);
                     }
                  } finally {
                     DatabaseUtil.closeResultSetQuietly(resultSet);
                  }
               } finally {
                  DatabaseUtil.closeStatementQuietly(statement);
               }
            } finally {
               DatabaseUtil.closeConnectionQuietly(connection);
            }
            transaction.commit();
            success = true;
         } finally {
            if (!success) {
               try {
                  transaction.rollback();
               } catch (DatabaseException e) {
                  ...
               }
            }
         }
      } catch (DatabaseException e) {
         ...
      } catch (SQLException e) {
         ...
      }
   }

   private void businessLogic(String name, int age) {
      // ...
   }
}

package sample.mytest;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.SQLException;

import jp.co.intra_mart.foundation.asynchronous.TaskControlException;
import jp.co.intra_mart.foundation.asynchronous.TaskManager;
import jp.co.intra_mart.foundation.database.DBTransaction;
import jp.co.intra_mart.foundation.database.DatabaseUtil;
import jp.co.intra_mart.foundation.database.TenantDatabase;
import jp.co.intra_mart.foundation.database.exception.DatabaseException;

public class DatabaseTaskRegister {
   ...

   private void addTask() {
      DBTransaction transaction = new DBTransaction();
      boolean success = false;
      try {
         transaction.beginTransaction();
         try {
            TenantDatabase database = new TenantDatabase();
            Connection connection = database.getConnection();
            try {
               for (int index = 0; index < 5; index++) {
                  String sql = "insert into my_test (id, name, age) values (?, ?, ?)";
                  PreparedStatement statementInsert = connection.prepareStatement(sql);
                  try {
                     statementInsert.setInt(1, index);
                     statementInsert.setString(2, "intra-mart " + index);
                     statementInsert.setInt(3, 26 + index);
                     statementInsert.execute();
                  } finally {
                     try {
                        statementInsert.close();
                     } catch (SQLException e) {
                        ...
                     }
                  }
               }
            } finally {
               DatabaseUtil.closeConnectionQuietly(connection);
            }
            transaction.commit();
            success = true;
         } finally {
            if (!success) {
               try {
                  transaction.rollback();
               } catch (DatabaseException e) {
                  ...
               }
            }
         }
      } catch (DatabaseException e) {
         ...
      } catch (SQLException e) {
         ...
      }

      try {
         TaskManager.addParallelizedTask("sample.mytest.DatabaseTask", null);
      } catch (TaskControlException e) {
         ...
      }
   }
   ...
}

package sample.mytest;

import java.io.IOException;
import java.nio.charset.Charset;

import jp.co.intra_mart.foundation.asynchronous.AbstractTask;
import jp.co.intra_mart.foundation.service.client.file.PublicStorage;

public class StorageTask extends AbstractTask {

   @Override
   public void run() {
      PublicStorage storage = new PublicStorage("/task/sample/test.txt");
      String text = null;
      try {
         text = storage.read(Charset.forName("UTF-8"));
      } catch (IOException e) {
         ...
      }
      businessLogic(text);
   }

   private void businessLogic(String text) {
      ...
   }
}

package sample.mytest;

import java.io.IOException;
import java.nio.charset.Charset;

import jp.co.intra_mart.foundation.asynchronous.TaskControlException;
import jp.co.intra_mart.foundation.asynchronous.TaskManager;
import jp.co.intra_mart.foundation.service.client.file.PublicStorage;

public class StorageTaskRegister {
   ...

   private void addTask() {
      String content = "name:intra-mart,age:26";
      PublicStorage storage = new PublicStorage("/task/sample/test.txt");

      try {
         storage.write(content, Charset.forName("UTF-8"));
      } catch (IOException e) {
         ...
      }

      try {
         TaskManager.addParallelizedTask("sample.mytest.StorageTask", null);
      } catch (TaskControlException e) {
         ...
      }
   }
   ...
}