並行プログラミング

並行プログラミングの目的

Java言語ではスレッド(thread, 「thread of control」(制御の糸)の短縮形) と呼ばれる自立的に動く単位を実行主体として並列性を制御する．論理的に並 列というのは，本当に並列に動くのではなく，一つの計算機上で時分割 (time-sharing)に動くことも許す(というより，大多数の実装ではそうなってい る)ことを意味する．スーパーコンピュータ用の FORTRAN処理系などでは，for ループを書くと自動的に並列化するものもあるが，Javaはこれらと違って明示 的な(explicitな)並列実行の指定をおこなっていて，スレッドを生成したとこ ろでのみ並列性が現われる．

Unix上のC言語でもプロセス(あるいはOSのスレッド)を生成して，並行プログ ラムを書くことができるが，Java言語ではライブラリではなく言語の中核部分 に並行プログラムを支援するための仕組みを入れているので，書きやすいし， OSに依存しない書き方ができる．

論理的に並列に書くと自然に書けるプログラムは次のようなものである．

• 実際に二つ以上のことを同時にする．たとえば一つのプログラムで GUI を制御するスレッドと，計算をするスレッド，ファイル I/O を実行するスレッ ドを作ると，どれかのスレッドがリソースを待ってブロックしても他のスレッ ドは実行できる．
• サーバ/クライアントシステムのサーバプログラムは，1つのクライアン トごとにスレッドを生成するとプログラムが書きやすい．スレッドを使わない と，各クライアントのリクエストの状態を明示的に保持しなければいけない．
• ある種のプログラムは本質的に並列処理である．スレッドを使って書く と分かりやすく書ける．このようなプログラムにはソート，マージ，行列演算， 再帰アルゴリズムがある．

新しいスレッドを取得する方法

• Thread のサブクラスを作り，run() を定義しておく．このクラスのインスタンスを作り，startメソッドを呼ぶと動き出す．これは，アプリケーションによく使われる．
• Runnable インタフェースを実装するクラスを作成する．このクラスの インスタンスを引数として，新たなThreadインスタンスを作り，startメソッ ドを呼ぶと動き出す．上の方法が使えない場合(他のクラスのサブクラスとし て定義したい時)，特にアプレットなどで使われる．

Threadクラスにはrun メソッド以外に，スレッドの実行を制御するための startメソッドがある．また，Threadクラスの静的メソッドとしてsleep(ミリ秒 単位での休止) もあり，よく使われる．

両方の方法で，スレッドを作るプログラムのサンプルを見てみよう．

// 2つのスレッドを作るクラス ThreadSample
public class ThreadSample {
  public static void main(String [] args){
  // Threadのサブクラス ExtnfThreadのインスタンスt1の作成
    ExtnOfThread t1 = new ExtnOfThread();
    // スレッド t1 の実行開始
    t1.start();

    // Runnableを実装(implement)したクラスのインスタンスを元に
    // Thread クラスのインスタンス t2 を作る
    Thread t2=new Thread(new ImplOfRunnable());
    // スレッド t2 の実行開始
    t2.start();
  }
}
// ThreadのサブクラスExtnOfThreadの宣言
class ExtnOfThread extends Thread{
// Threadをstartすると，このrunが呼ばれる
  public void run(){
    System.out.println("Extension of Thread running");
    // 1000ミリ秒 (=1秒)の間，スリープ(実行中断)
    // その間に別の割り込み(interrupt)に割り込まれた時は終了する
    try{sleep(1000);}
    catch(InterruptedException ie){return;}
    System.out.println("Extension of Thread exiting");
  }
}

class ImplOfRunnable implements Runnable{
  public void run(){
    System.out.println("Implementation of Runnable running");
    // このオブジェクトを実行しているスレッドをThread.currentThread()で得る
    // ことができる
    try{Thread.sleep(1000);}
    catch(InterruptedException ie){return;}
    System.out.println("Implementation of Runnable exiting");
  }
}

Extension of Thread running
Implementation of Runnable running
Extension of Thread exiting
Implementation of Runnable exiting