欢迎您访问365答案网,请分享给你的朋友!
生活常识 学习资料

C#异步操作Task类使用

时间:2023-07-11
一、多线程同步

何为线程同步,其实就是数据串行操作,当前当前的资源在没有操作完毕之前,不允许其他的线程对同一资源进行操作。即当有一个线程在对内存进行操作时,其他线程都不可以对这个内存地址进行操作,直到该线程完成操作, 其他线程才能对该内存地址进行操作,而其他线程又处于等待状态,实现线程同步的方法有很多,互斥量就是其中一种。

在C#中使用互斥量 Mutex即可进行线程同步。创建一个全局的Mutex对象,使用Mutex对象的WaitOne()和ReleaseMutex()方法。

WaitOne()方法作用等待Mutex对象被释放,如果不调用ReleaseMutex()方法,则另一线程在执行到WaitOne()这行回等待上一线程的ReleaseMutex()执行完毕。

ReleaseMutex()方法作用释放Mutex对象,此方法调用完毕后,另一线程再能继续执行。

下面例子为多线程进行数据插入操作,注意在执行ReleaseMutex()方法时需要在finally的括号内,如果程序异常了,执行不到ReleaseMutex()的方法,此线程则进入死锁状态,无法再次执行了

mutex.WaitOne(); try { string sqlstr = "insert into XMLTable(KSCS,LSH,KSLSH,XM,SFZMHM,KSXM,KSSJ,JSSJ,KFDM,JKID,XML,Flag) values (@KSCS,@LSH,@KSLSH,@XM,@SFZMHM,@KSXM,@KSSJ,@JSSJ,@KFDM,@JKID,@XML,@Flag) "; SqliteParameter[] sqlparam = { new SqliteParameter("KSCS",DbType.String), new SqliteParameter("LSH",DbType.String), new SqliteParameter("KSLSH",DbType.String), new SqliteParameter("XM",DbType.String), new SqliteParameter("SFZMHM",DbType.String), new SqliteParameter("KSXM",DbType.String), new SqliteParameter("KSSJ",DbType.String), new SqliteParameter("JSSJ",DbType.String), new SqliteParameter("KFDM",DbType.String), new SqliteParameter("JKID",DbType.String), new SqliteParameter("XML",DbType.String), new SqliteParameter("Flag",DbType.String) }; sqlparam[0].Value = kscs; sqlparam[1].Value = lsh; sqlparam[2].Value = kslsh; sqlparam[3].Value = xm; sqlparam[4].Value = sfzmhm; sqlparam[5].Value = ksxm; sqlparam[6].Value = kssj; sqlparam[7].Value = jssj; sqlparam[8].Value = kfdm; sqlparam[9].Value = jkid; sqlparam[10].Value = XML; sqlparam[11].Value = 0;//0712 if (sqliteMono.ExecuteNonQuery(sqlstr, sqlparam) > 0) { Ret = true; } } catch (Exception ex) { CLog.log.WriteIntoFile(ex); } finally { mutex.ReleaseMutex(); } return Ret;

Copyright © 2016-2020 www.365daan.com All Rights Reserved. 365答案网 版权所有 备案号:

部分内容来自互联网,版权归原作者所有,如有冒犯请联系我们,我们将在三个工作时内妥善处理。