C#多线程编程的同步也线程安全
前一篇文章记录了简单的多线程编程的几种方式,但是在实际的项目中,也需要等待多线程执行完成之后再执行的方法,这个就叫做多线程的同步,或者,由于多个线程对同一对象的同时操作造成数据错乱,需要线程安全。这篇文章主要记录多线程的同步异步如何实现线程安全的几种方式的笔记,如有错误,请大神不吝赐教。
因为代码里面有很详细的注释,所以下面直接附上代码,不做过多的解释,如有疑问可以百度相关主题的文章详细了解。
1、 mutex
////1.mutex测试
////mutex互斥锁，用于多线程间的线程同步通过waitone等待当前锁定的线程执行完成,例如，线程b执行需要等待线程a执行结束的情况下，可以使用mutex
////同时mutex还有一个比较有趣的功能就是可以设置实现客户端在同一太电脑上只能打开一个进程
//bool createnew = false;
//mutex mutex = new mutex(true, "mutextest", out createnew);
//autoresetevent ae = new autoresetevent(false);//定义一个信号量，表示执行结束，可以释放互斥锁
////参数1表示初始化的时候当前互斥锁是否已被获取，false代表未被获取，
////参数2标识当前互斥锁的名称，指定一个名称，配合参数3即可实现只能开启一个进程的效果
////参数3表示是否创建了一个新的互斥锁
//thread t1 = new thread(new threadstart(() =>
//{
// console.writeline("我是线程1");
// console.writeline("线程1开始执行!");
// thread.sleep(1000);//线程休眠1秒钟，用于模拟需要较长时间执行的功能
// console.writeline("线程1执行结束!");
// ae.set();
//}));
//thread t2 = new thread(() =>
// {
// console.writeline("我是线程2");
// console.writeline("线程2开始执行!");
// mutex.waitone();//等待互斥锁被释放，模拟实际项目中需要其他线程执行完毕方可执行的功能
// console.writeline("线程2执行结束!");
// });
////因为是多线程执行，所以线程1与线程2的谁先开始执行，以上代码中未进行控制，
////但线程2一定是在线程1执行完成之后才能结束
//t1.start();
//t2.start();
//ae.waitone();//等待释放信息
//mutex.releasemutex();//释放互斥锁
////autoresetevent的功能类似于一个红绿灯信号，当达到可以释放的条件的时候，调用set方法来通知后续代码可以执行了，
////此处为何需要一个信号，是因为mutex定义在主线程中，如果在异步线程中释放，会报一个错，提示在不安全的代码块中执行
////互斥锁,所以此处使用信号来通知主线程可以释放互斥锁了
2、autoresetevent
/// <summary>
/// 通过autorestevent实现线程同步
/// </summary>
public void testautoresetevent()
{
autoresetevent[] autoresetevents = new autoresetevent[3];
autoresetevents[0] = new autoresetevent(false);//定义初始信号为关
autoresetevents[1] = new autoresetevent(false);
autoresetevents[2] = new autoresetevent(false);
//以下代码实现线程1结束之后线程2才能结束,线程2结束之后线程3才能开始,所有线程都结束之后主线程才能继续
thread t1 = new thread(new threadstart(() =>
{
console.writeline("线程1开始!");
thread.sleep(1000);
console.writeline("线程1结束!");
autoresetevents[0].set();
}));
thread t2 = new thread(new threadstart(() =>
{
console.writeline("线程2开始!");
thread.sleep(1000);
autoresetevents[0].waitone();
console.writeline("线程2结束!");
autoresetevents[1].set();
}));
thread t3 = new thread(new threadstart(() =>
{
autoresetevents[1].waitone();
console.writeline("线程3开始!");
thread.sleep(1000);
console.writeline("线程3结束!");
autoresetevents[2].set();
}));
t1.start();
t2.start();
t3.start();
console.writeline("主线程开始等待......");
autoresetevents[2].waitone();//等待所有线程结束
//autoresetevent从字面即可知道是自动信号,意思为当信号被捕捉之后会自动重置为关闭状态
//对应的manualresetevent为手动信号,使用方法相同但是在被捕捉之后不会被重置为关闭状态
//需要手动调用reset方法关闭信号,如果是简单的同步,使用自动信号即可,如果需要很复杂的流程控制
//可以使用自动信号,同时可以配合waithandle来实现线程的同步,waithandle拥有waitany方法等待任意一个信号
//waitall方法等待所有信号,使用方法与信号的waione相似,此处不再进行举例,可以查看相关文章具体了解
console.writeline("主线程执行结束!");
}
3、 lock与monitor
/// <summary>
/// 测试lock和monitor实现线程安全的多线程
/// </summary>
public void testlockandmonitor()
{
//lock与monitor实现相同的功能，多线程的线程安全
//lock实际上就是monitor.enter与monitor.exit的语法糖
object obj = new object();//创建一个应用类型用于lock
int count = 1;
int sum = 0;
for (int i = 0; i < 20; i++)
{
thread t = new thread(new threadstart(() =>
{
for (int j = 0; j < 1000; j++)
{
//此处保证线程安全的原理是,当前多个线程同时访问count的时候,如果不lock
//可能多个线程访问到的count是相同的值,这样虽然多个线程都执行了count++但是
//结果却没有加上去,造成最终的结果错误,当lock之后，lock内部的代码每次只能
//有一个线程访问,所以每个线程获取的count都不可能相同,这样就能保证最后的结果一定是正确的
//lock (obj)//取消此句代码测试多线程的不安全性,取消之后可能每次执行的结果都不一样
//{
// sum += count;
// count++;
//}
//使用下面的方法与使用lock的功能相同
//monitor.enter(obj);
//sum += count;
//count++;
//monitor.exit(obj);
}
}));
t.start();
}
thread.sleep(3000);//延时3秒保证异步线程全部执行完成
console.writeline(sum);
}
4、信号量
/// <summary>
/// 测试信号量实现线程安全
/// </summary>
public void testsemaphore()
{
//semaphore 类似于线程池,用于设置同时可以有多少个线程执行
//当线程超过信号量运行的最大值之后,后续的线程就需要等待
semaphore semaphore = new semaphore(2, 2);//用于设置最大可以有两个线程同时执行,初始时有两个位置空闲
for (int i = 0; i <= 20; i++)
{
thread t = new thread(new threadstart(() =>
{
semaphore.waitone();//等待信号释放,若未超过信号的最大数值,则不需等待
console.writeline(thread.currentthread.managedthreadid.tostring() + datetime.now.tostring("yyyy-mm-dd hh:mm:ss"));
random random = new random();
thread.sleep(random.next(1,5) * 1000);//随机休眠1-5秒
semaphore.release();//释放当前信号
}));
t.start();
}
}
5、 自旋锁
/// <summary>
/// 测试自旋锁
/// </summary>
public void testspinlocked()
{
//自旋锁与lock实现的功能相同,但是lock锁住对象开销比较大
//相反自旋锁开销比较小,效率相对也比lock高,当锁住的次数比较多,同时锁的时间比较短的时候,可是使用自旋锁
int count = 1;
int sum = 0;
spinlock spinlock = new spinlock();
for (int i = 0; i < 20; i++)
{
thread t = new thread(new threadstart(() =>
{
bool locktaken = false;
//使用下面的方法与使用lock的功能相同
//申请获取锁
spinlock.enter(ref locktaken);
for (int j = 0; j < 1000; j++)
{
sum += count;
count++;
}
if (locktaken) //判断当前线程是否锁住,如果锁住则释放它,防止出现死锁的情况
{
spinlock.exit();
}
}));
t.start();
}
thread.sleep(3000);//延时3秒保证异步线程全部执行完成
console.writeline(sum);
}
6、 原子操作
/// <summary>
/// 测试interlocked
/// </summary>
public void testinterlocked()
{
//interlocked拥有几个方法来保证线程安全,每个操作都是原子级的，所以效率高,线程安全
//此方法使用interlocked实现类似于自旋锁的功能
//关于interlocked的更多用法请参考msdn
double current = 0;
for (int i = 0; i < 10; i++)
{
thread t = new thread(new threadstart(() =>
{
while (interlocked.exchange(ref current, 1) == 1)
{
//此循环用于等待当前捕获current的线程执行结束
}
console.writeline(thread.currentthread.managedthreadid.tostring() + datetime.now.tostring("yyyy-mm-dd hh:mm:ss"));
random random = new random();
thread.sleep(random.next(1, 3) * 1000);//随机休眠1-3秒
interlocked.exchange(ref current, 0);//将current重置为0
}));
t.start();
}
}
以上的代码仅仅是笔记用途,没有深入讲解各个方式的优缺点及用途,只是大概的解释知道的这些方法,有兴趣的话，大家可以结合每一个主题的文章详细了解其用法及优缺点，谢谢!