0

C#にて、セマフォのやり方についての質問です。

プロセスCにWndProcのプロシージャを起動させておきます。
プロセスA,BはプロセスCにプロセス間通信にてwinメッセージを送ります。
プロセスCは受け取ったWinメッセージによって、データベースへアクセスし処理を行います。

プロセスA → 
        プロセスC
プロセスB →
(A,B,Cは別々のアプリです)

以前、プロセスAとプロセスBで2つ同時にWinメッセージが来た際に、処理としては1つの
Winメッセージの処理を終了してから、もう1つのWinメッセージの処理を行うという回答を
頂きました。
(今回はプロセスCにデータベースへアクセスし処理をするという動作が新たに加わっています。)

質問は、シングルスレッド時のセマフォの取得の仕方をご教授願いたいと思っております。
上記の以前の質問の回答からプロセスCはシングルスレッドであるため、セマフォを取得する必要はないと思うのですが、
一応念のため、セマフォを取得し同時データベースへアクセスし処理を行わないようにしたいと思っています。
(同時に処理を行うということはないと思うのですが・・・)

やり方をご教授いただければ幸いです。よろしくお願いいたします。
雑なコードで申し訳ございません。
プロセスCのWndProc↓↓↓

    public partial class Form1 : Form
    {
        public Form1()
        {
            InitializeComponent();
        }

        protected override void WndProc(ref Message m)
        {
            const int WM_M = ****;//プロセスA,BからWinメッセージ
            base.WndProc(ref m);
            if (m.Msg == WM_CHAR)
            {
         datbase db = new datbase;
                db.aaaa(ref m);/* データベースアクセスメソッド */
            }
            else
            {
                base.WndProc(ref m);
            }
        }
    }

datbaseクラス↓↓↓

    public class datbase
    {
        public void aaaa()
        {
            if (プロセスA)
            {
                セマフォ取得;
                データベースアクセスして処理;
                セマフォ解放;
            }
            else if (プロセスB)
            {
                セマフォ取得;
                データベースアクセスして処理;
                セマフォ解放;
            }
        }
    }
1

2 件の回答 2

4
 protected override void WndProc(ref Message m)
 {
     const int WM_M = ****;//プロセスA,BからWinメッセージ
     base.WndProc(ref m);
     if (m.Msg == WM_CHAR)
     {
         datbase db = new datbase;
         db.aaaa(ref m);/* データベースアクセスメソッド */
     }
     else
     {
         base.WndProc(ref m);
     }
 }

ここだけ見ても大量の問題を抱えています。

  • WM_CHARはキー入力のためのメッセージであり他の用途に使うべきではありません。(誤字かもしれませんが)
  • m.Msg != WM_CHARの場合にbase.WndProc(ref m);を2回呼び出すことになっています。どのような状況であってもbase呼び出しは1回以下となるようにコードを記述する必要があります。
  • 全角空白を用いたインデントは避けるべきです。

そして最大の問題は WndProc内で時間のかかる処理をしてはいけない ということです。データベースアクセスなどもってのほかです。WndProcとは別のスレッドでデータベースアクセスすべきです。

一応念のため、セマフォを取得し同時データベースへアクセスし処理を行わないようにしたいと思っています。
(同時に処理を行うということはないと思うのですが・・・)

誰かの指示でしょうか? 現状では全く不要です。ただし前述のようにWndProcとは別のスレッドでデータベースアクセスした際に必要となるスレッド同期について説明します。
ここで「セマフォ」が語だけ先行していて意味を正確にとらえていない可能性があります。.NETには同期プリミティブが多数用意されています。Semaphoreのほかにもpgrhoさんの紹介されたMutexEventWaitHandleもあります。1つの処理だけの実行を許可するという機能においてSemaphoreは適切ではなくMonitor(クリティカルセクション)が最適です。Monitorクラスを直接使う必要はなく、C#言語に用意されているlockステートメントを推奨します。

1

System.Threading.Semaphoreを使用する場合、あらかじめSemaphoreのインスタンスを作成しておく必要があります。質問の要件では初期許可数1、同時実行数1ですので

private Semaphore semaphore = new Semaphore(1, 1);

とすればよいでしょう。なお並行する処理ではおなじセマフォを使用する必要がありますが、アセンブリやプロセスが異なりインスタンスを直接共有できない場合は名前付きのコンストラクターとSemaphore.OpenExistingメソッドを使用します。

Semaphoreの取得と解放にはsemaphore.WaitOne()メソッドとsemaphore.Release()を使用します。通常は確実にReleaseを呼び出すためにtry-finallyステートメントで

semaphore.WaitOne();
try
{
    データベースアクセスして処理;
}
finally
{
    semaphore.Release();
}

と記述します。

なお同時実行数が1の場合はSemaphoreではなくMutexEventWaitHandleを利用することが出来ます。

この質問に回答するには、ログインする必要があります。

求めていた回答ではありませんか? のタグが付いた他の質問を参照する。