上次講到ThreadLocal的使用場景,這次接著講。
管理應用程序的線程安全
使用ThreadLocal來實現(xiàn)線程安全,我覺得得有兩個前提
- 數(shù)據(jù)資源并非只有一個,即不需要非要競爭同一個資源
- 多線程情況下不能使用同一個數(shù)據(jù)資源
而數(shù)據(jù)庫連接就是這一類資源。數(shù)據(jù)庫連接可以有多個,但是是優(yōu)先的。而且不同線程間不可以使用相同的數(shù)據(jù)庫連接,不然事務無法保證。下面我們就來實現(xiàn)一個沒有池化功能數(shù)據(jù)庫連接管理功能
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
public class ConnectionManager
{
private static final ThreadLocal<Connection> connectionHolder = new ThreadLocal<Connection>();
public static Connection getConnection()
{
// ThreadLocal取得當前線程的connection
Connection conn = connectionHolder.get();
// 如果ThreadLocal沒有綁定相應的Connection,創(chuàng)建一個新的Connection,
// 并將其保存到本地線程變量中。
if (conn == null)
{
try
{
Class.forName("");
conn = DriverManager.getConnection("url", "user_name", "password");
// 將當前線程的Connection設置到ThreadLocal
connectionHolder.set(conn);
}
catch (ClassNotFoundException e)
{
// do not do like this
}
catch (SQLException e)
{
// do not do like this
}
}
return conn;
}
/**
* 關閉Connection,清除集合中的Connection
*/
public static void closeConnection()
{
// ThreadLocal取得當前線程的connection
Connection conn = connectionHolder.get();
// 當前線程的connection不為空時,關閉connection.
if (conn != null)
{
try
{
conn.close();
// connection關閉之后,要從ThreadLocal的集合中清除Connection
connectionHolder.remove();
}
catch (SQLException e)
{
// do not do like this
}
}
}
}
線程內(nèi)的數(shù)據(jù)傳遞
之前在搜索部門做過一個系統(tǒng),是用來解析關鍵字的系統(tǒng)。而對于不同的關鍵字所配置的業(yè)務規(guī)則時不相同的,而且業(yè)務規(guī)則之間有優(yōu)先級的概念。所以該系統(tǒng)整體上是使用責任鏈的設計模式來架構設計的??傮w類似于下面這種。

也許你會說,有必要使用ThreadLocal來傳遞參數(shù)嗎,直接使用一個RequestParamVo對象來封裝所有的參數(shù)不就行了嗎。實際上也是可以的。這里我只不過提供另外一種實現(xiàn)思路而已。
所以我建議如果使用ThreadLocal來傳遞參數(shù)并沒有給你帶來多少好處的話,我建議不要使用ThreadLocal
下面我們來介紹一個使用ThreadLocal使得數(shù)據(jù)傳遞特別方便的案例。
使用ThreadLocal來實現(xiàn)讀寫分離,具體可參考koala
PS:注意切面的順序
某些情況下的性能優(yōu)化
- 某些資源沒有必要多線程競爭,所以可以使用ThreadLocal這種以空間換時間的方式來提高性能
- 有些時候線程執(zhí)行的時候需要初始化某些耗費時間的資源,這個時候就可以在線程執(zhí)行前來初始化這些資源,并且將這些資源綁定到當前線程上,以避免重復初始化。
比如,在做分布式session的時候,我們是把session存儲到redis中了,所以在調(diào)用HtppSession的getAttribute方法的時候,實際上是在調(diào)用HtppSession的代理對象,而該代理對象實際上是在調(diào)用redis的get命令。如果程序比較正常的話,那么直接調(diào)用redis的命令就可以了。但是如果出現(xiàn)下面的代碼,那將是災難性的。
HttpSession session = getSession();
for(int i = 0;i < n ;i++){
String val = session.getAttribute("som key");//執(zhí)行了n次redis的命令調(diào)用
this.doSomething(val);
}
所以我們可以將session中的數(shù)據(jù)在線程啟動的時候一次性load到內(nèi)存中,然后綁定到該線程上。這樣之后在調(diào)用HttpSession的getAttribute方法時,實際上是從ThreadLocal中緩存的數(shù)據(jù)中獲取的。具體的時候可以使用Filter來實現(xiàn)。順便說一句,HttpSession的代理對象也可以在Filter中來設置。不可該Filter的優(yōu)先級應該高于其他所有的Filter。這里就不貼代碼了。