リソースまたはリソースのプールに同時にアクセスできるスレッドの数を制限できます。これはSemaphoreクラスの軽量な代替です。
public SemaphoreSlim (
int initialCount,
int maxCount
);
SemaphoreSlim(Int32, Int32) - SemaphoreSlim コンストラクター (System.Threading) | Microsoft Learn
maxCountを省略するとInt32.MaxValueに設定されます。SemaphoreSlim - SemaphoreSlim.cs
| 型 | プロパティ | 内容 |
|---|---|---|
| int | CurrentCount | SemaphoreSlimオブジェクトに入ることができる、残りのスレッド数 |
| WaitHandle | AvailableWaitHandle | セマフォの待機に使用できるWaitHandle |
SemaphoreSlim semaphore = new SemaphoreSlim(3); // 初期値はコンストラクタで指定する int c1 = semaphore.CurrentCount; // 3 semaphore.Wait(); // 減算される int c2 = semaphore.CurrentCount; // 2 semaphore.Release(); // 加算される int c3 = semaphore.CurrentCount; // 3
CurrentCountが1以上となり、SemaphoreSlimに入れるまで現在のスレッドはブロックされます。この待ちをタイムアウトさせるにはWait(Int32)を、非同期に待たせるにはWaitAsync()を呼びます。
public void Wait ();
SemaphoreSlimに入れたときはCurrentCountが1減算されます。
SemaphoreSlim semaphore = new SemaphoreSlim(1);
semaphore.Wait();
try
{
// クリティカル セクション
}
finally
{
semaphore.Release();
}
SemaphoreSlimに入れないときにスレッドをブロックせず、即座に結果を返すようにするにはタイムアウトを0とします。
SemaphoreSlim semaphore = new SemaphoreSlim(1);
if (semaphore.Wait(0))
{
try
{
}
finally
{
semaphore.Release();
}
}
else { } // SemaphoreSlimに入れなかった
SemaphoreSlimに入れるまで非同期に待たせられます。
public System.Threading.Tasks.Task WaitAsync ();
返されるTaskは、SemaphoreSlimに入ったときに完了します。
SemaphoreSlimを1つ解放できます。
public int Release ();
CurrentCountが1加算され、加算前の値が返されます。
SemaphoreSlimクラスを簡潔に記述できるようにしたクラスです。