かんたんな「SemaphoreSlim」の使い方

同時に仕事をできる机（Task）の数を決めるのが、SemaphoreSlimです。

基本

//机を２つ用意
SemaphoreSlim ss = new SemaphoreSlim(2);

//机が１つ埋まる
ss.Wait();

//机がさらに１つ埋まる
ss.Wait();

//2つとも埋まった机のうち、１つだけ空ける
ss.Release(1);

//空いてる机の数を確認
Console.WriteLine(ss.CurrentCount);
//実行結果は、1

Waitで机を使う。
Releaseで机を空けるか、新しい机を用意する。
CurrentCountで机の数を確認

かんたんな例

using System;
using System.Threading;
using System.Threading.Tasks;

class Program {
    static void Main(string[] args) {

        SemaphoreSlim ss = new SemaphoreSlim(0);    //最初は、机を１つも作らない
        ss.Release(1);      //机を１つだけ追加

        //机が１つしかないので、作業１だけが実行される
        Task task1 = Task.Run(() =>{ss.Wait();  Console.WriteLine("作業１");});
        Task task2 = Task.Run(() =>{ss.Wait();  Console.WriteLine("作業２");});

        //1つしかない机は、作業１で埋まっているので、0
        Console.WriteLine(  ss.CurrentCount);

        Console.ReadLine();
    }
}

Taskを実行しようとしても、空いてる机の数しか実行されない

引数

SemaphoreSlim ss = new SemaphoreSlim(1, 6); 

第１引数は、机の数（あとから追加できる）
第２引数は、机の最大数
机は１つしかないが、最大６つまで増やせられる。

SemaphoreSlim ss = new SemaphoreSlim(1); 

引数は机の数（最大数は未設定なので、あとからいくらでも追加できる）

Waitと、WaitAsyncの違い

using System;
using System.Threading.Tasks;
using System.Threading;
using System.Collections.Generic;

class Program {
    static void Main(string[] args) {
        Sub();
        Console.WriteLine("main");      //A
        Console.ReadLine();
    }
    public static async Task Sub() {
        SemaphoreSlim ss = new SemaphoreSlim(2);
        List<Task> list = new List<Task>();
        int num = 10;

        while(num-- > 0) {
            await ss.WaitAsync();       //B     Aが先に実行される（非同期）
            //ss.Wait();                //C     Aが後に実行される（同期）

            list.Add(   Task.Run(   () => {
                Thread.Sleep(100);
                Console.WriteLine("-");
                ss.Release();
            }));
        }
        await Task.WhenAll(list);
    }
}

Waitは、呼び出し元を待機させ（同期）
WaitAsyncは、待機させません（非同期）

Waitメソッドは入れたらTrueを返します。
既に満席で入れなかったらFalseを返します。

キャンセル

CancellationToken　はまず　CancellationTokenSource　を生成した上で、
CancellationTokenSource.Token　より取得します。

キャンセルを要求するには　CancellationTokenSource.Cancel()　を呼びます。

つづく・・・