[C#]椅子取りゲーム(複数人が同一イベントを同時に発火し、先着１名のみtrueになる)イベントの実装

Question

前提・実現したいこと

FileSystemWatcherによってファイルが変更されたことを感知した時、そのデータをDBに書き込んだ後、DBからデータを取得してDataGridViewで表示する処理を作成しています。
本プログラムは1人以上10人以下が同時に起動しています。
その際、起動している全員が同時にファイルの変更を感知し、DBに書き込むことで、同一のレコードが起動している人数分だけ複製されてしまいます。

そこで、変更の感知後、先着１名がDBを更新し、残りの人はDBの更新を待機する処理を実装したいです。

該当のソースコード

private FileSystemWatcher _watcher = new FileSystemWatcher();
public WatchForm()
{
    InitializeComponent();

    // フォームが呼び出されたとき、フォルダの監視を開始する
    _watcher.Path = Properties.Resources.Folder;
    _watcher.Filter = "*.csv"
    _watcher.IncludeSubdirectories = true;
    _watcher.NotifyFilter = (NotifyFilters.FileName | NotifyFilters.CreationTime | NotifyFilters.LastWrite);
    _watcher.Created += new FileSystemEventHandler(OnResultChanged);
    _watcher.Changed += new FileSystemEventHandler(OnResultChanged);
    _watcher.Deleted += new FileSystemEventHandler(OnResultChanged);
    _watcher.EnableRaisingEvents = true;
}

private void OnResultChanged(object sender, FileSystemEventArgs eventArgs)
{
    // 更新権限を持つ人なら
    if(HasReloadAuthority())
    {
        // ファイルを読み取り、DBに書き込む
        Program.DataBaseReload();
    }
    else
    {
        // 更新権限を持つ人が更新を完了するまで待つ
        Wait()
    }

    // フォームをリロードする(DBからデータを取得し、DataGridViewを更新する)
    WatchForm_Load(sender, eventArgs);
}

private bool HasReloadAuthority()
{
    // 先着１名のみ更新権限を持たせる処理
}

補足情報（FW/ツールのバージョンなど）

.NET Framework 4.6.1
Windows アプリケーション

Answer 1

その際、起動している全員が同時にファイルの変更を感知し、DBに書き込むことで、同一のレコードが起動している人数分だけ複製されてしまいます。

そこで、変更の感知後、先着１名がDBを更新し、残りの人はDBの更新を待機する処理を実装したいです。

待機させたい理由が同一レコードになってしまう、という点だけであれば、DBに何を使用しているかは判りませんが、シーケンス等で自動採番するカラムを追加すれば良いと思います。

Comments

[woria]

DBにはSQL Serverを使用しており、TableAdapter().Update()を使って更新処理を実装しています。
設計段階でシーケンス番号は付与していませんでしたが、手詰まりになったら採用してみます。

[退会済みユーザー]

SQL Serverを使用しているのであれば、タグと補足情報に追記した方が良いと思われます。SQL Server詳しい人からコメントが付くかもしれませんし。

[woria]

ありがとうございます。タグにSQLを追加します。

Answer 2

System.Threading.Mutex を使えばプロセスをまたいだ排他制御が可能なので、
これを使って先着一名のみが更新/二番目以降は待機できるのでは。

Comments

[woria]

System.Threading.Mutex確認してみます。

[woria]

更新処理を非同期で記載しており、asyncを利用する際はSemaphoreSlimを利用すると記載されているため、そちらを確認しています。

[dodox86]

＞@質問者さん

> asyncを利用する際はSemaphoreSlimを利用すると記載されているため、そちらを確認しています。

質問者さんのアプリの構成がいまいち分からないのですけど、こちらのリファレンスを見ると、
https://docs.microsoft.com/ja-jp/dotnet/api/system.threading.semaphoreslim?view=netframework-4.6.1

> SemaphoreSlimクラスは、単一のアプリ内で同期するために推奨されるセマフォです。

とあるので、複数プロセス間での排他制御には使えないのではないでしょうか。
（外れた指摘でしたらすみません）

[woria]

SemaphoreSlimだと「先着１名のみ更新作業、残りは更新作業を行わない」という分岐処理ができない？みたいなので、更新作業は同期処理で書き直してMutex試してみます。

[woria]

SemaphoreSlimだと複数アプリ間での排他制御には使えないんですね。ありがとうございます。

Answer 3

DBの更新処理にトランザクション処理を加えることで、同時起動した時に排他制御するように処理を変更しました。回答いただいた方々、ありがとうございました。