C#多线程同步lock、Mutex的实现
更新时间：2024年05月30日 09:02:51 作者：猪猪加大码力
本文主要介绍了C#多线程同步lock、Mutex的实现,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧
C#使用多线程可以通过System.Threading命名空间下的Thread类来实现
lock和Mutex用于实现线程同步的机制：
上代码：
class People
{
public People(int idd)
{
id = idd;
}
public int id;
public int age;
}
class TestHelper
{
public TestHelper() { }
List<People> m_data = new List<People>();
int m_iComplete;
private void LockThread(object obj)
{
List<object> parameters = (List<object>)obj;
int idx = (int)parameters[0];
while (true)
{
People data = null;
lock(this)
{
if (m_iComplete >= m_data.Count)
{
return;
}
data = m_data[m_iComplete];
Interlocked.Increment(ref m_iComplete);
data.age = data.id;
Console.Write("======");
Console.WriteLine("id:" + data.id.ToString() + ",age:" + data.age.ToString());
}
}
}
//测试lock
public void TestLock()
{
DateTime time1 = DateTime.Now;
m_iComplete = 0;
m_data.Clear();
for (int i = 0; i < 10000;i++)
{
m_data.Add(new People(i + 1));
}
List<Thread> threads = new List<Thread>();
for (int i = 0; i < Environment.ProcessorCount; i++)
{
Thread th = new Thread(LockThread);
th.IsBackground = true;
List<object> objs = new List<object>();
objs.Add(i + 1);
th.Start(objs);
threads.Add(th);
}
foreach (var th in threads)
{
th.Join();
}
DateTime time2 = DateTime.Now;
TimeSpan deltaTime = time2.Subtract(time1);
Console.Write("===================耗时: ");
Console.WriteLine(deltaTime.TotalSeconds);
}
Mutex m_mutex = new Mutex();
private void MutexThread(object obj)
{
List<object> parameters = (List<object>)obj;
int idx = (int)parameters[0];
while (true)
{
People data = null;
//开启
m_mutex.WaitOne();
if (m_iComplete >= m_data.Count)
{
//释放
m_mutex.ReleaseMutex();
return;
}
data = m_data[m_iComplete];
Interlocked.Increment(ref m_iComplete);
data.age = data.id;
Console.Write("======");
Console.WriteLine("id:" + data.id.ToString() + ",age:" + data.age.ToString());
//释放
m_mutex.ReleaseMutex();
}
}
//测试mutex
public void TestMutex()
{
DateTime time1 = DateTime.Now;
m_iComplete = 0;
m_data.Clear();
for (int i = 0; i < 10000; i++)
{
m_data.Add(new People(i + 1));
}
List<Thread> threads = new List<Thread>();
for (int i = 0;i<Environment.ProcessorCount;i++)
{
Thread th = new Thread(MutexThread);
List<object> objs = new List<object>();
objs.Add(i + 1);
th.Start(objs);
threads.Add(th);
}
foreach(var th in threads)
{
//同步等待
th.Join();
}
DateTime time2 = DateTime.Now;
TimeSpan deltaTime = time2.Subtract(time1);
int sec = (int)deltaTime.TotalSeconds;
Console.Write("===================耗时: ");
Console.WriteLine(deltaTime.TotalSeconds);
}
}
测试：
起多个线程计算：
总结：
1、Lock是C#中的关键字，用于对代码块进行同步。Lock只能用于同一进程内的线程同步。轻量级的同步机制，开销比较小，使用简单，不能用于跨应用程序域的线程同步。
2、Mutex是系统级别的同步对象，用于跨进程的线程同步。 Mutex是内核对象，因此创建和销毁代价高，用于跨应用程序域的线程同步。
到此这篇关于C#多线程同步lock、Mutex的实现的文章就介绍到这了,更多相关C#多线程同步lock、Mutex内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！
相关文章
这篇文章主要为大家介绍了c# EPPlus秘籍之Excel实现图表导出示例详解,有需要的朋友可以借鉴参考下,希望能够有所帮助,祝大家多多进步,早日升职加薪2023-12-12
这篇文章主要给大家介绍了基于C#实现的多边形冲突检测的相关资料,文中介绍的方法并未使用第三方类库,可以完美解决这个问题,需要的朋友可以参考下2021-07-07
这篇文章主要为大家详细介绍了C#实现循环发送电脑屏幕截图，文中示例代码介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们可以参考一下2021-07-07
这篇文章主要介绍了C#队列Queue多线程用法,实例分析了队列的相关使用技巧,需要的朋友可以参考下2015-05-05
这篇文章主要介绍了c# 判断指定文件是否存在的简单实现,需要的朋友可以参考下2014-02-02
这篇文章详细介绍了C#垃圾回收机制，有需要的朋友可以参考一下2013-09-09
这篇文章主要介绍了C#中使用HttpDownLoadHelper下载文件的方法,并实例讲述了在webfrom中与在mvc中的实现方法,需要的朋友可以参考下2014-10-10
这篇文章主要介绍了C#数据绑定(DataBinding)简单实现方法,以简单实例形式简单分析了C#实现数据绑定与读取的方法,具有一定参考借鉴价值,需要的朋友可以参考下2015-08-08
下面小编就为大家分享一篇C# out关键词的应用实例，具有很好的参考价值，希望对大家有所帮助。一起跟随小编过来看看吧2017-12-12
本文主要介绍了C#调用Python脚本程序的两种方法,包含介绍了通过C#IronPython开源库和通过Process类来运行python解释器这两种,具有一定的参考价值,感兴趣的可以了解一下2024-02-02
最新评论