.NET並行処理プログラミング入門8

　この記事は.NET並行処理プログラミング入門7の続きです。今回も、実行するスレッドを切り替える機能を解説します。
　前回のサンプルプログラムの内容は、重要度が低いAの処理よりも、重要度が高いスレッドBの処理を先に終わらせるというものです。このサンプルのキーは、Threadクラスの静的メソッドYieldです。
　Yield静的メソッドを使用すると、他のスレッドが実行する機会を与えるようOSに指示を出します。しかし、必ず他のスレッドが実行できるとは限りません。なんらかの理由でOSが他のスレッドを実行できなかった場合false（偽）を返します。たとえば、他に実行可能なスレッドがない場合falseが返されます。
　前回のサンプルプログラムで、Yield静的メソッドの戻り値をチェックしていたのはこのためです。また、trueを返した場合も、どのスレッドが実行されたのかは、工夫しないと分からない事を考慮せねばなりません。あくまでもYield静的メソッドはOSに対して、他のスレッドを実行するように指示するだけなのです。
　数回に渡ってSleepメソッドとYieldメソッドを解説しました。この2つのメソッドを知れば、並行処理プログラミングの世界が少し見えてきます。ただし、この2つのメソッドは多用してはなりません。奥の手として使用して下さい。何故ならば、この2つのメソッドが必要な時は、大概アルゴリズムそのものが間違っているからです。設計が間違っていなければ、この2つのメソッドは必要ない筈です。
　とはいえ、特殊な状況下では必要となります。また、この2つのメソッドを使用すれば、スレッドをコントロールする事が出来ますので、並行処理のテスト時には大きな力となります。地味ですが、背景知識とともに覚えておくべきメソッドと言えます。

.NET並行処理プログラミング入門7

　この記事は.NET並行処理プログラミング入門6の続きです。前回は、スレッドの処理を一時中断する機能について解説しました。今回は、実行するスレッドを切り替える機能を解説します。
　並行処理プログラミングをしていると、別のスレッドの処理を実行したい場面に遭遇します。たとえば、重要でないが計算量が少ないもののアプリケーションが終了するまで実行するスレッドAの処理と、有限で重要だが処理量が多いスレッドBの処理を並行処理していると仮定します。
　この場合、スレッドAの処理ばかり実行されてしまい、重要なスレッドBの処理終了が遅くなる可能性があります。この問題を解決するには、スレッドAの処理を中断し、スレッドBの処理を優先的に実行する必要があります。
　幸いThreadクラスには、別のスレッドの処理を実行する為に、実行するスレッドを切り替える機能があります。早速その方法を見てみましょう。

using System;
using System.Threading;

class YieldSample
{
    //Bスレッドが処理を終えた場合true
    static bool isComplete = false;

    static void Main( string[] args )
    {
        Thread a = new Thread( new ThreadStart( AThreadMethod ) );
        Thread b = new Thread( new ThreadStart( BThreadMethod ) );
        a.Start();
        b.Start();
        a.Join();
        b.Join();
    }

    //あまり重要でない処理
    static void AThreadMethod()
    {
        //Bスレッドが実行されるまで待つ
        while ( Thread.Yield() == false | isComplete == false );
        Console.WriteLine( "スレッドAの処理が終了しました。" );
    }

    //絶対先に終了させたい処理
    static void BThreadMethod()
    {
        Console.WriteLine("スレッドBの処理が終了しました。");
        isComplete = true;
    }
}

長くなったので次回解説します。

.NET並行処理プログラミング入門6

　この記事は、.NET並行処理プログラミング入門5の続きです。引き続きThreadクラスが持つ機能とスレッドの概念について解説します。
　早速ですが新しいスレッドの機能を紹介します。ひとまずサンプルを見て下さい。

using System;
using System.Threading;

class TimeStop
{
    static void Main( string[] args )
    {
        //約3000ミリ秒（3秒）間メインスレッドを止める
        Console.WriteLine( "時が止まる。" );
        Thread.Sleep( 3000 );
        Console.WriteLine( "そして動き出す。" );
    }
}

このサンプルコードを実行すると、まるで時が止まったかのようにプログラムが約3秒間停止し、その後メッセージを出力して終了します。メインスレッドの動きを止めたのはThread.Sleep静的メソッドです。
　Sleep静的メソッドの引数にはミリ秒単位の値を指定して実行します。Sleep静的メソッドを実行すると、引数で指定した値に等しいミリ秒間、実行したスレッドの動きを止めます。ここで注意してほしい事は、Sleep静的メソッドは正確な時間を保証できない事です。あくまでも約指定ミリ秒間、実行したスレッドの動きを止めるだけです。
　正確な時間を保証できない理由は、WindowsOSがリアルタイムOSではないからです。.NET FrameworkはOS上で動作していますので、リアルタイムな動作を保証しないOS上では正確に時間を管理できません。将来リアルタイムOSの上で動作する.NET Frameworkが登場した際には、正確な時間が期待できるかもしれませんが、ひとまず正確な時間を指定する事は不可能だと考えて下さい。続く...
　

.NET並行処理プログラミング入門5

　この記事は、.NET並行処理プログラミング入門4の続きです。引き続きThreadクラスが持つ機能とスレッドの概念について解説します。
　早速ですが、前回提示した問題があるサンプルを改良したものを掲載し、それを元に解説します。

using System;
using System.Threading;

class ThreadSample
{
    static void Main( string[] args )
    {
        //専用のスレッドで計算をする
        AdditionMan addMan = new AdditionMan();
        ParameterizedThreadStart addStart =
            new ParameterizedThreadStart( addMan.Calculation );
        Thread addThread = new Thread( addStart );
        int maxValue = 10;
        addThread.Start( maxValue );
        addThread.Join(); //処理の流れを合流する

        //計算結果を表示
        Console.WriteLine( "1 ～ {0} までの数を足すと{1}になります。",
            maxValue, addMan.Sum );
    }
}

class AdditionMan
{
    private long m_sum;
    public long Sum { get { return this.m_sum; } }

    public void Calculation( object value )
    {
        int max = ( int ) value;
        for ( int i = 1; i <= max; i++ ) this.m_sum += i;
    }
}

前回との違いは緑色で表示したコードだけです。ThreadクラスのJoinメソッドを呼び出す事により、前回のコードにあった不備を解決できます。
　Joinメソッドは呼びだし元のスレッドを、ブロックさせる効果があります。このサンプルの場合、Joinメソッドを呼び出したメインスレッドの動きを止め、新しく作成したスレッドの処理が終了した後再開します。Joinメソッドを呼び出さないと、メインスレッドは計算処理を待たずに自身の処理を進行し、計算処理が終わる前に終了してしまいます。それで前回のサンプルは、計算結果が0になってしまうのです。この処理の流れを並行処理プログラミング初心者は分かり難いと思います。並行処理プログラミングに慣れる為に、処理の流れが合流するとイメージするとよいでしょう。そうすれば簡単に感じます。
　Joinメソッドが合流するイメージである理由は、スレッドは処理の流れとイメージするとよいからです。Thread（スレッド）という単語は、「糸、細い流れ、話の筋、全体を一つにつなぐ特徴」などを意味するので、処理が流れる様子をイメージするとしっくりきます。
　この様にスレッドをイメージし、メインスレッドの処理の流れと、計算専用の処理が別に流れる様をイメージすると、並行処理プログラミングが分かりやすくなります。

.NET並行処理プログラミング入門4

　この記事は.NET並行処理プログラミング入門3の続きです。前回は、スレッドの種類と複数のスレッドの実行について解説しました。今回はThreadクラスが持つ機能とスレッドの概念について解説します。
　スレッドを扱えるようになると、特定の処理を専用のスレッドで実行したくなります。特定の処理を他のスレッドに任せれば、メインスレッドは処理を続けられるので、同時に2つの処理が出来るようになり非常に便利です。
　簡単な加算処理を他のスレッドに任せるプログラムのサンプルを元に、この事について考えてみます。

using System;
using System.Threading;

class ThreadSample
{
    static void Main( string[] args )
    {
        //専用のスレッドで計算をする
        AdditionMan addMan = new AdditionMan();
        ParameterizedThreadStart addStart =
            new ParameterizedThreadStart( addMan.Calculation );
        Thread addThread = new Thread( addStart );
        int maxValue = 10;
        addThread.Start( maxValue );

        //計算結果を表示
        Console.WriteLine( "1 ～ {0} までの数を足すと{1}になります。",
            maxValue, addMan.Sum );
    }
}

class AdditionMan
{
    private long m_sum;
    public long Sum { get { return this.m_sum; } }

    public void Calculation( object value )
    {
        int max = ( int ) value;
        for ( int i = 1; i <= max; i++ ) this.m_sum += i;
    }
}

このサンプルが行っている事は実に簡単です。スレッドを作成し、１～10までの数を合計する処理を、作成したスレッドで実行しているだけです。
　注目するべき所はParameterizedThreadStartデリゲートを使用している点と、ThreadオブジェクトのStartメソッドに値を渡している点です。ParameterizedThreadStartデリゲートを使用してThreadのコンストラクタを呼び出すと、スレッドの処理開始時（Startメソッド呼び出し時）に値を渡せるようになります。ただし、デリゲートで指定するメソッドは、Object型の引数を1つ受け取るものでなくてはなりません。注意して下さい。
　このサンプルを実行すると合計値は何になると思いますか？多くの人は55と答えると思います。しかし、実際に実行してみると違う結果を表示します。
※55と表示される場合はもっと大きな数を指定して下さい。
　その理由と対策について次回解説します。

.NET並行処理プログラミング入門3

　この記事は.NET並行処理プログラミング入門2の続きです。前回はスレッドの生成方法および実行方法を解説しました。今回はスレッドの種類と複数のスレッドの実行について解説します。
　前回のサンプルは並行処理をしている実感が得られなかったと思います。そこで、今回は2つのスレッドを実行するサンプルを掲載し、スレッドオブジェクトについての解説を進めます。

using System;
using System.Threading;

class ThreadSample
{
    static void Main( string[] args )
    {
        //カウントスレッドを用意
        ThreadStart start = new ThreadStart( Piyo.Count );
        Thread counter = new Thread( start );

        //ピヨスレッドを用意
        Piyo p = new Piyo();
        ThreadStart piyoStart = new ThreadStart( p.PiyoOut );
        Thread piyopiyo = new Thread( piyoStart );
        piyopiyo.IsBackground = true;

        //二つのスレッドを実行
        counter.Start();
        piyopiyo.Start();
    }
}

class Piyo
{
    public Piyo() { }
    public void PiyoOut()
    {
        while( true ) {
            Console.WriteLine(" ピヨ ");
        }
    }

    public static void Count()
    {
        Console.WriteLine( "数えるピヨ♪" );
        for ( long i = 0; i < 1000; ++i ) {
            Console.Write( "{0} ", i );
        }
        Console.WriteLine();
    }
}

このサンプルは一見すると、ピヨスレッドの処理が終わらないので、永遠に処理が続くように見えます。しかし、実際はちゃんと終了します。その理由は、バックグラウンドスレッドが他の種類のスレッドに強制終了させられるからです。
　非並行処理の.NETのプログラムが動いているのは、メインスレッドが動作しているからです。そして、サンプルのカウントスレッドのようなフォアグラウンドスレッドが動いている間プログラムは終了しません。フォアグラウンドスレッドは、全ての処理が終了すると、全てのバックグラウンドスレッドを停止しプログラムを終了させます。
　フォアグラウンドスレッドとバックグラウンドスレッドの違いは重要なので絶対に覚えて下さい。どういう観点で使い分けるのかの目安を言います。バックグラウンドスレッドは途中で終了しても支障がないサブ処理で使用します。一方、フォアグラウンドスレッドは、途中で終了すると不都合がある処理で使用します。
注意：これはあくまでも目安なので、実務で使用する前にこの連載の続きやMSDNをよく読んで下さい。
　バックグラウンドスレッドは、処理の途中で強制的に終了させられるので十分に注意して使用して下さい。バックグラウンドスレッドで処理をする場合は、いきなり処理が終了させられる可能性があるので扱うデータの整合性を保てるように工夫しましょう。続く...

.NET並行処理プログラミング入門2

　この記事は.NET並行処理プログラミング入門1の続きです。前回は.NETにおけるスレッドモデルについて解説します。今回はスレッドの生成方法および実行方法を解説します。
　何はともあれ、先ずはスレッドを生成して実行してみましょう。スレッドの生成方法と、生成したスレッドの実行方法をサンプルで示します。

using System;
using System.Threading;

class ThreadSample
{
    static void Main( string[] args )
    {
        ThreadStart start = new ThreadStart( Piyo.Count );
        Thread counter = new Thread( start );
        counter.Start();
    }
}

class Piyo
{
    public static void Count()
    {
        Console.WriteLine("数えるピヨ♪");
        for ( long i = 0; i < 100; ++i ) {
            Console.Write( "{0} ", i );
        }
        Console.WriteLine();
    }
}

サンプルを見て、スレッドの生成および実行が意外と簡単な事に驚いた人もいるかと思います。スレッドモデルによる並行処理プログラミングの概念は難しいもののコーディングは簡単です。
　.NETのSystem.Threading.Threadオブジェクトは、System.Threading.ThreadStartデリゲートを引数として受け取るコンストラクタを呼び出す事によりインスタンスを生成します。他にもコンストラクタがあるのですが、ひとまずこの方法を覚えて下さい。
　Threadオブジェクトのインスタンス取得後は、Startメソッドを呼び出すだけで実行できます。これで.NET並行処理プログラミングの第一歩を踏み出した事になります。色々気になる事があるかと思いますが、長くなるので今回は終わります。
　次回へ続く...

.NET並行処理プログラミング入門1

　この記事は、.NET並行処理プログラミング入門の続きです。前回は並行処理に関する基礎的事柄を解説しました。今回は.NETにおけるスレッドモデルについて解説します。
　.NET Frameworkでのプログラミングは実行環境を提供しており、Win32を使ったネイティブなプログラミングとは異なります。.NET Frameworkにおける並行処理実行環境を知るところから始めるのがベストです。そこで、先ずはWin32のスレッドモデルをおさらいし、次に.NET Frameworkのスレッドモデルを解説します。両方のスレッドモデルを理解する事により、並行処理の理解が深まり、スレッドを自由自在に操れるようになります。
　Windowsが管理しているネイティブなスレッドはプロセス内に存在します。Windowsはプロセス内に、共有リソースと1つ以上のスレッドを保持します。こうする事により、バグを抱えたプログラムの影響を限定化する事が出来ます。もし仮にプロセス内ではなく、全スレッドが同一空間に管理されていると、一つのスレッドの過ちがOS全体に影響を与えてしまいます。プロセス内のプログラムは通常他のプロセスのプログラムにアクセスできないのでその心配がなくなります。
　一方.NET Frameworkでは、プロセス内に1つ以上のアプリケーションドメインを持ちます。そして、アプリケーションドメイン内で共有リソースとスレッドを保持しています。一見複雑化しただけですがこの方式には利点があります。
　アプリケーションドメイン内でスレッドを保持する事により、さらにバグの影響範囲を限定し、プログラムがより一層堅牢になります。それに加えて、アプリケーションドメインごとにセキュリティ等の構成を設定でき、アセンブリのロード＆アンロードも行えます。アプリケーションドメインという概念があるお陰で、プログラムの構成がさらに堅牢かつ柔軟になると言えます。
　先ほどWindowsが管理するスレッドをネイティブなスレッドと表現しました。この理由は、.NET FrameworkのスレッドがOSが管理するスレッドと一対一で対応しなくなる可能性があるからです。.NET Frameworkは今のところ.NETのスレッド＝Windowsのスレッドですが、マイクロソフト社は将来のバージョンでパフォーマンスやセキュリティ上の理由で.NETのスレッドを抽象化するかもしれません。これは重要ですので覚えて下さい。
　覚えるべき事はまだまだ沢山ありますが、一度に沢山解説しても退屈なだけなので今回はひとまず終わりにします。次回からサンプルを交えつつ、.NET並行処理プログラミングの解説を進めます。続く...

.NET並行処理プログラミング入門

　マルチコア化が一般化した今、並行処理／並列処理はプロならば必須の知識／技術と言えるでしょう。しかしながら、日々の業務に追われている人が習得するのは困難です。そこで、.NETにおける並行処理／並列処理を解説する事にしました。
　先ずは用語をはっきりさせます。並行処理と並列処理という言葉があります。その違いはなんでしょうか？それは、並列処理はマルチコアCPUが複数の処理を同時に理実行する事を指すのに対して、並行処理は実際には同時に実行されていない状態も指すという点にあります。並行処理という用語は並列処理を包合していると言えます。
　何故二つの用語が存在すのかといいますと、マルチコアCPUが一般していない状況下では、OSが同時に実行しているかのように見せる必要があったからです。シングルコアCPU専用のプログラムと、マルチコアCPU専用のプログラムをプログラミングし、それを保守するのは大変な事です。そこで、OSが見せかけの同時実行を並行処理機能として提供する事になりました。
　ですが、複数のプログラムが同時に実行される事を前提としたい場合もあります。それだと、マルチコアCPUのプログラムをプログラミングする場合ややこしいので、区別する為に並列処理という言葉が生まれました。それが似た用語が存在する理由です。
　この連載では、並行処理と並列処理の両方を扱いますが、書き分けるのは面倒ですし、並行処理は並列処理の意味も含むので並行処理と表記する事にします。
　.NETには並行処理と並列処理が存在します。その豊富な機能を理解するのは大変で、OSの実装やコンパイラの実装経験がないと理解できない事が多いです。それに加えて、.NET FreamworkはWin32のラッパーの役割も果たすので、WindowsOS特有の知識も必要となります。でもそこは心配ご無用。極力簡潔かつ適切に背景知識も書きます。次回から本格的に解説をします。