• 设为首页
  • 点击收藏
  • 手机版
    手机扫一扫访问
    迪恩网络手机版
  • 关注官方公众号
    微信扫一扫关注
    公众号

c#解决高并发--加锁(Lock)

原作者: [db:作者] 来自: [db:来源] 收藏 邀请
private static object sign = new object();

        public static DBHelper CreateMapping(string connStr = "")
        {
            DBHelper db = new DBHelper(connStr);
            return db;
        }

        /// <summary>
        /// 增删改的数据库连接字符串
        /// </summary>
        string conString = "";
        /// <summary>
        /// 查询的数据库连接字符串
        /// </summary>
        string queryConString = "";

        DBHelper(string connStr = "")
        {
            if (string.IsNullOrWhiteSpace(connStr))
            {
                conString = AsString(ConfigurationManager.ConnectionStrings["DBConfig"]);
                if(string.IsNullOrEmpty(conString))WriteErrorLogDataInteraction(conString,"连接字符串获取失败!");
                //第一个链接字符串是ConfigurationManager.ConnectionStrings[0].Name LocalSqlServer不知道是谁,所以要从第二个取
                //如果连接字符串的数量和当前索引+1相同 则从第一个索引开始取
                NameValueCollection connStrs = new NameValueCollection();
                int j = 0;
                for (int i = 0; i < ConfigurationManager.ConnectionStrings.Count; i++)
                {
                    if (ConfigurationManager.ConnectionStrings[i].Name.StartsWith("QueryDB"))
                    {
                        connStrs.Add(j.ToString(), ConfigurationManager.ConnectionStrings[i].ToString());
                        j++;
                    }
                }
                // 加锁
                lock (sign)
                {
                    if (connStrs.Count > 0)
                    {
                        if (connStrs.Count >= ConnIndex)
                        {
                            ConnIndex = 0;
                        }
                        queryConString = connStrs[ConnIndex].ToString();
                        ConnIndex++;
                    }
                    else
                    {
                        queryConString = conString;
                    }
                }
            }
            else
            {
                conString = connStr;
                queryConString = connStr;
            }

            DBMapping = new SqlDatabase(conString);
            QueryDBMapping = new SqlDatabase(queryConString);

        }

DBHelper如果多个进行同时运行时,就会出现错误。所以应该加上锁Lock 。以确保一个线程执行完之后再执行另一个线程。


鲜花

握手

雷人

路过

鸡蛋
该文章已有0人参与评论

请发表评论

全部评论

专题导读
热门推荐
阅读排行榜

扫描微信二维码

查看手机版网站

随时了解更新最新资讯

139-2527-9053

在线客服(服务时间 9:00~18:00)

在线QQ客服
地址:深圳市南山区西丽大学城创智工业园
电邮:jeky_zhao#qq.com
移动电话:139-2527-9053

Powered by 互联科技 X3.4© 2001-2213 极客世界.|Sitemap