在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进行举报,并提供相关证据,一经查实,将立刻删除涉嫌侵权内容。