C# 异步操作Task类使用(二)

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

在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;