您好,登錄后才能下訂單哦!
在C#中,可以使用System.Threading.Semaphore
類來實現多進程間的信號量同步。信號量是一種同步原語,用于控制對共享資源的訪問。它允許多個進程或線程同時訪問資源,但會限制同時訪問的數量。
下面是一個簡單的示例,展示了如何在C#中使用信號量實現多進程間的同步:
首先,創建一個名為SemaphoreExample
的控制臺應用程序項目。
在Program.cs
文件中,編寫以下代碼:
using System;
using System.Diagnostics;
using System.Threading;
namespace SemaphoreExample
{
class Program
{
static void Main(string[] args)
{
// 創建一個名為"MySemaphore"的信號量,初始值為3,最大值為5
using (Semaphore semaphore = new Semaphore(3, 5, "MySemaphore"))
{
// 啟動5個子進程
for (int i = 0; i < 5; i++)
{
Process process = new Process();
process.StartInfo.FileName = "SemaphoreChildProcess.exe";
process.StartInfo.Arguments = i.ToString();
process.Start();
}
// 等待所有子進程退出
while (true)
{
int currentCount = semaphore.Release();
if (currentCount == 3)
{
break;
}
Thread.Sleep(100);
}
}
}
}
}
創建一個名為SemaphoreChildProcess
的新控制臺應用程序項目。
在Program.cs
文件中,編寫以下代碼:
using System;
using System.Threading;
namespace SemaphoreChildProcess
{
class Program
{
static void Main(string[] args)
{
// 獲取傳入的參數
int processId = int.Parse(args[0]);
// 打開名為"MySemaphore"的信號量
using (Semaphore semaphore = Semaphore.OpenExisting("MySemaphore"))
{
// 請求信號量
semaphore.WaitOne();
Console.WriteLine($"Process {processId} is running.");
Thread.Sleep(2000); // 模擬資源訪問
Console.WriteLine($"Process {processId} has finished.");
// 釋放信號量
semaphore.Release();
}
}
}
}
SemaphoreChildProcess
項目設置為啟動項目,并運行。你將看到5個子進程按順序運行,每次只有3個子進程同時運行。這是因為我們創建了一個初始值為3的信號量,限制了同時訪問資源的進程數量。免責聲明:本站發布的內容(圖片、視頻和文字)以原創、轉載和分享為主,文章觀點不代表本網站立場,如果涉及侵權請聯系站長郵箱:is@yisu.com進行舉報,并提供相關證據,一經查實,將立刻刪除涉嫌侵權內容。