スレッド間で共有される変数にはintを使うなかれ。AtomicIntegerを使うべし。

うっかり忘れそうなのでメモ。

【ダメダメな例】

MyThread

package org.yyama;

public class MyThread extends Thread {
    public static final int LOOP = 10000000; // 1000万回 ループ
    public static int counter = 0;

    @Override
    public void run() {
        for (int i = 0; i < LOOP; i++)
            counter++;
    }
}

Main

package org.yyama;

public class Main {
    private static final int THREAD_COUNT = 2; // スレッド2個で調査

    public static void main(String[] args) throws Exception {
        // MyThreadの配列を作成
        MyThread[] t = new MyThread[THREAD_COUNT];
     
        for (int j = 0; j < THREAD_COUNT; j++) {
            // MyThreadのインスタンスを作成し、実行
            t[j] = new MyThread();
            t[j].start();
        }
     
        // 全スレッドの処理が終わるまで待つ
        while (Thread.activeCount() != 1) {
            Thread.sleep(100);
        }
     
        // 結果と期待値を出力
        System.out.println("result  :" + MyThread.counter);
        System.out.println("expected:" + (MyThread.LOOP * THREAD_COUNT));
    }
}

実行結果

result  :14190209

expected:20000000

インクリメントしようとして、インクリメントできていないときが600万回くらいあります。
「int型をインクリメントするくらいで、スレッド間の競合を考えなくてもいいだろ。」という考えはスパっと切り捨てましょう。


【正しい例】
MyThreadだけ書き換えます。

MyThread

package org.yyama;

import java.util.concurrent.atomic.AtomicInteger;

public class MyThread extends Thread {

    public static final int LOOP = 10000000; // 1000万回 ループ

    public static AtomicInteger counter = new AtomicInteger(0);

    @Override

    public void run() {

        for (int i = 0; i < LOOP; i++)

            counter.getAndIncrement();

    }

}

今度は大丈夫です。

実行結果

result  :20000000

expected:20000000

【もうひとつの正しい例】
もちろんsynchronizedを使ってもかまいません。
ただし、処理時間でAtomicIntegerに負けるそうです。

また、MyThreadのみ変更します。

MyThread

package org.yyama;

public class MyThread extends Thread {

    public static final int LOOP = 10000000; // 1000万回 ループ

    public static int counter = 0;

    @Override

    public void run() {

        increment();

    }

    private static synchronized void increment() {

        for (int i = 0; i < LOOP; i++)

            counter++;

    }

}

これでも期待通りの結果が得られます。

参考にさせていただきました：
AtomicIntegerを追ってみた

Google App Engine とGitHub

最近は、もっぱら、GoogleAppEngine と GitHubの勉強をゆっくりと、ゆっくりと行っています。

1個、学習用アプリ作りました。
ひたすらコンピュータとじゃんけんをするという、何の意味もないアプリですが、
公開します。

アプリのURL：http://yyama-001.appspot.com/jangkeng
ソースのURL：https://github.com/yyama695/jangkeng.git

GitHubに関して、EclipseのプラグインであるEGitを使っているのですが、
いまいち、紹介しているサイトが少なくて、使い方があっているのかどうかも、
微妙な感じです。まあ、1人で作ったアプリだし、たいした問題も
ありませんでした。

アプリに対する指摘や、ソースに対する指摘は大歓迎です。

それでは第2弾の作成に移るとします。
では。

seasar2 AOP

seasar2を使った、簡単なAOPのサンプルです。
seasar2に用意されているorg.seasar.framework.aop.interceptors.TraceInterceptorをアドバイス（インターセプタ）としてそのまま利用しています。
org.seasar.framework.aop.interceptors.TraceInterceptorは、ポイントカットとなるメソッドの前後にメソッド名や引数、戻り値をコンソールに出力してくれるアドバイス（インターセプタ）です。

今回のサンプルでは、log4jは使用していません。
log4jのjarは、クラスパスに置いていないので、 自動でjava.util.logging.Loggerが使用されます。

org.seasar.framework.aop.interceptors.TraceInterceptorはデバッグレベルでログを出力します。
java.util.logging.LoggerのログレベルはFINEにしておいてください。
参考URL：http://www.alles.or.jp/~torutk/oojava/maneuver/2001/logging/logging.html

(1)パッケージ構成

（２）ソース

Driver.java

package org.yama.study.aop.pk1;

import org.seasar.framework.container.S2Container;
import org.seasar.framework.container.factory.SingletonS2ContainerFactory;

public class Driver {
    public static void main(String[] args) {
        SingletonS2ContainerFactory.init();
        S2Container container = SingletonS2ContainerFactory.getContainer();
        ClassAImpl ca = (ClassAImpl) container.getComponent("classA");
        ca.methodA();
        ca.methodB();
    }
}

ClassAImpl.java

package org.yama.study.aop.pk1;

public class ClassAImpl {
    public void methodA() {
        System.out.println("Hello Aop from methodA!");
    }
    public void methodB() {
        System.out.println("Hello Aop from methodB!");
    }
}

app.dicon

<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE components PUBLIC "-//SEASAR//DTD S2Container 2.4//EN"
"http://www.seasar.org/dtd/components24.dtd">
<components>
    <component name="traceInterceptor"
     class="org.seasar.framework.aop.interceptors.TraceInterceptor" />

    <component name="classA" class="org.yama.study.aop.pk1.ClassAImpl">
      <aspect>traceInterceptor</aspect>
    </component>
</components>

main()を実行すると以下の実行結果が得られます。

実行結果

（以下の出力以外に、seasar2本体のログが出力される場合もありますがテーマに関係ないので削除しました。）

普通: BEGIN org.yama.study.aop.pk1.ClassAImpl#methodA()
Hello Aop from methodA!
5 02, 2012 3:11:35 午後 org.seasar.framework.log.Logger debug
普通: END org.yama.study.aop.pk1.ClassAImpl#methodA() : null
5 02, 2012 3:11:35 午後 org.seasar.framework.log.Logger debug
普通: BEGIN org.yama.study.aop.pk1.ClassAImpl#methodB()
Hello Aop from methodB!
5 02, 2012 3:11:35 午後 org.seasar.framework.log.Logger debug
普通: END org.yama.study.aop.pk1.ClassAImpl#methodB() : null

メソッドの前後にログが出力されています。

続いてapp.diconを以下のように変更してみます。

app.dicon(修正後)

<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE components PUBLIC "-//SEASAR//DTD S2Container 2.4//EN"
"http://www.seasar.org/dtd/components24.dtd">
<components>
    <component name="traceInterceptor"
     class="org.seasar.framework.aop.interceptors.TraceInterceptor" />

    <component name="classA" class="org.yama.study.aop.pk1.ClassAImpl">
    <aspect pointcut="methodA">traceInterceptor</aspect>
    </component>
</components>

「<aspect pointcut="methodA">traceInterceptor</aspect>」の部分を修正しています。

すると、methodAの前後にだけアドバイスが織り込まれている（ウィービングされている）ことがわかります。

実行結果

（以下の出力以外に、seasar2本体のログが出力される場合もありますがテーマに関係ないので削除しました。）

5 02, 2012 3:42:14 午後 org.seasar.framework.log.Logger debug
普通: BEGIN org.yama.study.aop.pk1.ClassAImpl#methodA()
Hello Aop from methodA!
5 02, 2012 3:42:14 午後 org.seasar.framework.log.Logger debug
普通: END org.yama.study.aop.pk1.ClassAImpl#methodA() : null
Hello Aop from methodB!

Java Logging API ハマリポイント

Java Logging APIを使用して、はまった箇所の備忘録

Java Logging APIの基本的な使い方は、他のページを参照
・http://www.alles.or.jp/~torutk/oojava/maneuver/2001/logging/logging.html
・http://struts.wasureppoi.com/util/04_javalog.html


ロギングの簡単な操作を覚えるために簡単なサンプルを作成した。

Driver.java

package org.yama.study;

import java.util.logging.Logger;

public class Driver {
    private final Logger logger = Logger
            .getLogger("driver");

    public static void main(String[] args) {
        Driver dv = new Driver();
        dv.prccess();
    }

    private void prccess() {
        logger.finest("finest");
        logger.fine("fine");
        logger.config("config");
        logger.info("info");
        logger.warning("warning");
        logger.severe("severe");
    }
}

設定ファイル※1の内容（デフォルトのままいじらず）

logging.properties

############################################################
#   Default Logging Configuration File
#
# You can use a different file by specifying a filename
# with the java.util.logging.config.file system property.
# For example java -Djava.util.logging.config.file=myfile
############################################################

############################################################
#   Global properties
############################################################

# "handlers" specifies a comma separated list of log Handler
# classes.  These handlers will be installed during VM startup.
# Note that these classes must be on the system classpath.
# By default we only configure a ConsoleHandler, which will only
# show messages at the INFO and above levels.
handlers= java.util.logging.ConsoleHandler

# To also add the FileHandler, use the following line instead.
#handlers= java.util.logging.FileHandler, java.util.logging.ConsoleHandler

# Default global logging level.
# This specifies which kinds of events are logged across
# all loggers.  For any given facility this global level
# can be overriden by a facility specific level
# Note that the ConsoleHandler also has a separate level
# setting to limit messages printed to the console.
.level= INFO

############################################################
# Handler specific properties.
# Describes specific configuration info for Handlers.
############################################################

# default file output is in user's home directory.
java.util.logging.FileHandler.pattern = %h/java%u.log
java.util.logging.FileHandler.limit = 50000
java.util.logging.FileHandler.count = 1
java.util.logging.FileHandler.formatter = java.util.logging.XMLFormatter

# Limit the message that are printed on the console to INFO and above.
java.util.logging.ConsoleHandler.level = INFO
java.util.logging.ConsoleHandler.formatter = java.util.logging.SimpleFormatter

# Example to customize the SimpleFormatter output format
# to print one-line log message like this:
#     <level>: <log message> [<date/time>]
#
# java.util.logging.SimpleFormatter.format=%4$s: %5$s [%1$tc]%n

############################################################
# Facility specific properties.
# Provides extra control for each logger.
############################################################

# For example, set the com.xyz.foo logger to only log SEVERE
# messages:
com.xyz.foo.level = SEVERE

出力結果

出力結果

5 02, 2012 12:24:51 午後 org.yama.study.Driver prccess
情報: info
5 02, 2012 12:24:51 午後 org.yama.study.Driver prccess
警告: warning
5 02, 2012 12:24:51 午後 org.yama.study.Driver prccess
重大: severe

さて、ログレベルを変えてやってみるかと、設定ファイルを変更した。

logging.properties（抜粋）

#java.util.logging.ConsoleHandler.level = INFO　コメントアウト
java.util.logging.ConsoleHandler.level = FINEST

が、これでは、出力結果が変わらない！？


調査した結果、こっち↓も変えないといけなかった。

logging.properties（抜粋）

#.level= INFO　コメントアウト
.level= FINEST

無事に出力できました。

出力結果

5 02, 2012 12:31:17 午後 org.yama.study.Driver prccess

最も詳細: finest

5 02, 2012 12:31:17 午後 org.yama.study.Driver prccess

普通: fine

5 02, 2012 12:31:17 午後 org.yama.study.Driver prccess

構成: config

5 02, 2012 12:31:17 午後 org.yama.study.Driver prccess

情報: info

5 02, 2012 12:31:17 午後 org.yama.study.Driver prccess

警告: warning

5 02, 2012 12:31:17 午後 org.yama.study.Driver prccess

重大: severe

結局、グローバルログレベルでログ出力を制限し、さらにコンソールハンドラレベルでそれ以上に絞りたいのであれば絞ることができる。
したがって、コンソールハンドラレベルにおいて、グローバルログレベル以上のログを出力しようとしても無理なことが判明した。
（設定ファイル※1のコメントに「グローバルログレベルのほかに、コンソールハンドラでもレベルを設定できるから注意しろよ！」と英語で書いてあった。）

---

※1 JDKインストールディレクトリ以下の「～\lib\logging.properties」もしくは、JREインストールディレクトリ以下の「～\lib\logging.properties」。
このファイルは、すべてのアプリに対して影響するので、普通は編集しません。正しくは、アプリ固有の設定ファイルを準備し、そのファイルを参照しにいくようVMの起動パラメータを指定する必要があります。

seasar2 コンポーネント自動登録

seasar2のコンポーネント自動登録の基本

初めて使ったときに悩んだのでメモ。

コンポーネントの自動登録を理解するために、最もシンプルにしたプロジェクトでサンプルを提示します。

１．自動登録を使用しない場合（プロジェクト名：ComponentManualRegisterSample1）

（１）パッケージ構成

（２）各ソース

ClassAImpl.java

package org.yama.study.pk1;

public class ClassAImpl {
public void say() {
System.out.println("Hello Manual Registar!");
}
}

Driver.java

package org.yama.study.pk1;

import org.seasar.framework.container.S2Container;
import org.seasar.framework.container.factory.SingletonS2ContainerFactory;

public class Driver {
public static void main(String[] args) {
SingletonS2ContainerFactory.init();
S2Container container = SingletonS2ContainerFactory.getContainer();
ClassAImpl ca = (ClassAImpl) container.getComponent("classA");
ca.say();
  }
}

app.dicon

<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE components PUBLIC "-//SEASAR//DTD S2Container 2.4//EN"
"http://www.seasar.org/dtd/components24.dtd">
<components>
    <component name="classA" class="org.yama.study.pk1.ClassAImpl">
    </component>
</components>

mainを実行した結果

Hello Manual Registar!

２．自動登録を使用した場合（プロジェクト名：ComponentAutoRegisterSample1）

（１）パッケージ構成

さっきと一緒

（２）各ソース

ClassAImpl.java

package org.yama.study.pk1;

public class ClassAImpl {
public void say() {
// ↓↓↓　出力の文言を変えただけ。コンポーネントの自動登録には影響しない　↓↓↓
System.out.println("Hello Auto Registar!");
}
}

Driver.java
（さっきと一緒）

app.dicon

<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE components PUBLIC "-//SEASAR//DTD S2Container 2.4//EN"
"http://www.seasar.org/dtd/components24.dtd">
<components>
    <component         class="org.seasar.framework.container.autoregister.FileSystemComponentAutoRegister">
        <property name="autoNaming">
            <component class="org.seasar.framework.container.autoregister.DefaultAutoNaming"/>
        </property>
        <initMethod name="addClassPattern">
            <arg>"org.yama.study.pk1"</arg>
            <arg>".*Impl"</arg>
        </initMethod>
    </component>
</components>

mainを実行した結果

Hello Auto Registar!

３．いくつか解説

■自動登録する場合のapp.diconについて


app.dicon（抜粋）

        <initMethod name="addClassPattern">
            <arg>"org.yama.study.pk1"</arg>
            <arg>".*Impl"</arg>
        </initMethod>

1番目の引数は見てわかるとおり、自動登録するクラスのパッケージを指定しているが、
子供のパッケージも再帰的に検索するので、

        <initMethod name="addClassPattern">
            <arg>"org.yama.study"</arg>
            <arg>".*Impl"</arg>
        </initMethod>

や、

        <initMethod name="addClassPattern">
            <arg>"org"</arg>
            <arg>".*Impl"</arg>
        </initMethod>

でも、同様の動きとなった。

ただし、これはだめだった。

        <initMethod name="addClassPattern">
            <arg>""</arg>
            <arg>".*Impl"</arg>
        </initMethod>

デフォルトパッケージに自動登録したいクラスがあった場合、どうすればいいんだろう？
暇なときソースを追いかけてみるか。。。




■DefaultAutoNamingクラスの役割について

Driver.java（抜粋）

ClassAImpl ca = (ClassAImpl) container.getComponent("classA");

コンポーネントの自動登録をしない場合は、app.diconで明示的に「classA」という名前をコンポーネント名に設定している。一方、自動登録する場合には、「classA」というコンポーネント名は、どこにも設定していない。
にもかかわらず、「classA」というコンポーネント名が利用できるのは、app.diconで指定したDefaultAutoNamingクラスが、

app.dicon（抜粋）

        <property name="autoNaming">
            <component class="org.seasar.framework.container.autoregister.DefaultAutoNaming"/>
        </property>

自動でクラス名からコンポーネント名を導き出し、設定してるから。

サンプルの場合、以下のとおり。

・クラス名「org.yama.study.pk1.ClassAImpl」からパッケージ部分を除去し「ClassAImpl」という文字列を作成

    ↓

・「ClassAImpl」のImplを取り除き「ClassA」という文字列を作成

    ↓

・「ClassA」の先頭を小文字に変換し「classA」の出来上がり

この、変換ルールは、DefaultAutoNamingクラスのプロパティやメソッドで、ある程度変更可能。