本文介紹3種線程安全模式

1，lock

2，Mutex

3，MethodImpl

?

以前寫的一個(gè)MYSQL數(shù)據(jù)庫連接池ConnectionPool.CS

using System; using System.Collections.Generic; using System.Linq; using System.Text;using System.IO; using System.Threading; using MySql.Data.MySqlClient; using System.Runtime.CompilerServices; namespace queue.service.basic {public class ConnectionPool{private Stack<MySqlConnection> pool;private const int POOL_MAX_SIZE = 20;private int current_Size = 0;private string ConnString = "";//連接字符串 private SysProperty sysProperty;private const string SYS_PROPERTY = "config\\SysProperty.xml";private static ConnectionPool connPool;private ConnectionPool(){if (pool == null){pool = new Stack<MySqlConnection>();}}[MethodImpl(MethodImplOptions.Synchronized)]public static ConnectionPool getInstance(){if (connPool == null){connPool = new ConnectionPool();}return connPool;}public MySqlConnection getConnection(){MySqlConnection conn;lock (this){if (pool.Count == 0){if (current_Size < POOL_MAX_SIZE){conn = createConnection();current_Size++;//把conn加入到pool 中 pool.Push(conn);}else{try{Monitor.Wait(this);}catch (Exception e){Console.WriteLine(e.Message);}}}conn = (MySqlConnection)pool.Pop();}return conn;}private string GetConnString(){if (ConnString == ""){sysProperty = new SysProperty().LoadProperty(Path.Combine(SYS_PROPERTY));string ip = sysProperty.getPropertyValue("databaseIP");string dbName = sysProperty.getPropertyValue("databaseName");string userID = sysProperty.getPropertyValue("databaseUser");string userPwd = sysProperty.getPropertyValue("databasePassword"); ConnString = "Database=" + dbName +";Data Source=" + ip +";User Id=" + userID +";Password=" + userPwd + ";" +"pooling=true;CharSet=utf8;port=3306;";}return ConnString;}public void releaseConnection(MySqlConnection conn){lock (this){pool.Push(conn);Monitor.Pulse(this);}}private MySqlConnection createConnection(){lock (this){MySqlConnection newConn = new MySqlConnection(GetConnString());newConn.Open();return newConn;}}} }

總結(jié)：

1，上面類中使用了 主要使用了 lock 方式。

???? lock()是對一個(gè)對象加互斥鎖，只允許一個(gè)線程訪問其后大括號(hào)中語句塊，直到該語句塊的代碼執(zhí)行完才解鎖，解鎖后才允許其他的線程執(zhí)行其語句塊。

2，單例模式使用了懶漢模式。

???? 餓漢式是在類裝載的時(shí)候直接得到該類的實(shí)例，可以說是前期綁定的；懶漢式是后期綁定的，類加載的時(shí)候connPool是空的，在需要的時(shí)候才被創(chuàng)建且僅創(chuàng)建一次。餓漢式的速度快，效率高，但是耗費(fèi)系統(tǒng)資源；懶漢式則相反。懶漢式還存在一個(gè)問題，就是后期綁定不能確保對象只能被實(shí)例化一次，這需要對指示類是否實(shí)例化的標(biāo)志設(shè)置1個(gè)互斥鎖，僅允許1個(gè)線程訪問。這樣就可以確保對象只被實(shí)例化一次。

3，單例模式的線程安全使用了 MethodImpl。

他指定了getInstance()方法同時(shí)只能被一個(gè)線程使用。

4，使用Mutex類進(jìn)行同步

修改代碼為：

private static Mutex mutex = new Mutex();public static ConnectionPool getInstance(){mutex.WaitOne();if (connPool == null){connPool = new ConnectionPool();}mutex.ReleaseMutex();return connPool;}

?

轉(zhuǎn)載于:https://www.cnblogs.com/RushSykes/archive/2012/04/16/2451880.html

總結(jié)

以上是生活随笔為你收集整理的C# 数据库连接池 线程安全 单例模式 的实现的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。