ThreadLocal

一、ThreadLocal概述

本地線程變量

本質上是一種利用線程的執行由程序的上游向下游傳遞信息的機制

Thread對象內置了一個Map來存取消息 ， 但是這個 Map外界無法直接操作 ， 需要通過ThreadLocal來實現Thread中Map進行數據的存取

ThreadLocal就是用來實現Thread的Map存取過程的類

每一個線程保存各自自己的對象 ， 后續獲取來使用 ， 每個線程都有自己的對象自然不會有線程安全的問題

二、ThreadLocal方法

ThreadLocal t1 = new ThreadLocal:獲取當前線程 ， 并獲取線程中的map對象

t1.set(obj) : 向當前線程的map中存儲t1:obj鍵值對

t1.get():得到當前線程中的map ， 從map中查找t1對應的值并返回

t1.remove() : 移除map中的鍵值對

三、基于數據庫事務、ThreadLocal的實際案例

場景：添加商品

分析： 添加新的商品時 ， 需要先判斷商品種類表中是否有對應的種類 ， 如果有這個種類執行商品信息插入數據庫 ， 如果沒有這商品種類 ， 則在商品種類表中添加商品種類后 ， 將商品信息插入數據庫中 。 但是需要注意 ， 在數據庫中不允許出現有商品種類但是沒有對應商品的情況 ， 所以查詢商品種類表、添加商品種類 、 添加商品 ， 是一組操作 ， 要么都執行成功 ， 要么都不執行成功 。

應用技術： 數據庫事務操作查看詳情 、 ThreadLocal機制

實現思路分析：

當添加商品操作時 ， 將查詢商品種類表、添加商品種類 、 添加商品放到一組事務中 ， 也就是說這三個操作必須要使用同一個連接對象conn ， 在service層中統一開啟事務 ，執行完三個操作后統一提交事務后再統一釋放conn對象 。但是這種情況下操作數據庫的方法只能由service層調用 ， 如果在Service層中創建Connection conn對象 ， 再通過方法參數的傳遞將conn傳遞給dao層 ， 雖然可以實現功能 ， 但是違反了JavaEE經典三層架構的原理 ， 在Service層中竟然出現了Dao層特有的對象 ， 發生了耦合 。

如果這種耦合不可避免， 那么我們需要盡量將耦合管理起來 ， 把service層中的事務操作抽取到一個工具類中 ， 將Conn設置為static共享資源 ， 一組事務內的所有數據庫操作共享同一個 conn ， 這樣就實現了功能的需求 。

但是在并發情況下兩個用戶同時用一個conn對象 ， 勢必會發生事務的混亂 ， 比如發生后來的用戶提交了先來用戶未操作玩的事務 … 。 這時候需要引入ThreadLocal機制保證每一個用戶都有自己的conn ，從而實現了事務之間互不干涉的目的。

需要注意的是：

由于一組事務中的所有數據庫操作用的都是一個conn ， 所以在事務中的每一步操作完成后都不能釋放conn ， 必須等一組事務中的所有數據庫操作完成后統一釋放conn

代碼：

事務管理工具public class TransManage {private TransManage(){}private static ThreadLocal<Connection> tl = new ThreadLocal<Connection>();//獲取連接public static Connection getConn(){return tl.get();}//釋放資源public static void releaase(){Connection conn = tl.get();MySqlUtils.close(null, null, conn);tl.remove();}//開啟事務public static void startTrans(){try {Connection conn = MySqlUtils.getConn();conn.setAutoCommit(false);tl.set(conn);} catch (SQLException e) {e.printStackTrace();throw new RuntimeException(e);}}//提交事務public static void commitTrans(){try {tl.get().commit();} catch (SQLException e) {// TODO Auto-generated catch blocke.printStackTrace();}}//回滾事務public static void rollbackTrans(){try {tl.get().rollback();} catch (SQLException e) {// TODO Auto-generated catch blocke.printStackTrace();}}}service層執行一組事務private ProdDao dao =BaseFactory.getBase().getInstance(ProdDao.class);public void addProd(Prod prod) {try{//開啟事務TransManage.startTrans();//1.根據商品種類查詢Prod_category category = dao.findPordCategoryByName(prod.getCategory().getCategory());//2. 處理商品種類 int c_id = 0;if(category == null){//商品種類不存在， 添加商品種類Prod_category pc = new Prod_category();pc.setCategory(prod.getCategory().getCategory());dao.addprodcategory(pc);//并獲得商品種類的編號保存在商品信息中Prod_category findpc = dao.findPordCategoryByName(prod.getCategory().getCategory());c_id = findpc.getId();}else{//如果找到 ， 就查詢商品種類的編號保存在商品信息中c_id = category.getId();}//3. 將商品存入數據庫中prod.getCategory().setId(c_id);dao.addprod(prod);//沒有發生異常 ， 則提交事務TransManage.commitTrans();}catch(Exception e){//如果發生異常 ， 則回滾TransManage.rollbackTrans();throw new RuntimeException(e);}finally{//釋放資源TransManage.releaase();}}

總結

以上是生活随笔為你收集整理的大数据WEB阶段（十九）Threadlocal的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。