ThreadLocal 解決多線程程序的並發問題+事務處理

ThreadLocal 本地線程變量：

private static ThreadLocal<Connection> tl = new ThreadLocal<Connection>();
　　tl.get()：獲取的就是當前線程中map{tl:conn}中的conn
　　tl.set(conn):向當前線程中的map中保存一個元素{tl:conn}
　　tl.remove():從當前線程中的map移除key為tl的元素
　　initialValue():當調用get()獲取當前線程的map中元素時，如果不存在，則調用該方法創建一個，並保存到map中

 

 

import java.sql.Connection;
import java.sql.SQLException;

public class TranManager {
    private static ThreadLocal<Connection> tl=
                    new ThreadLocal<Connection>(){
        /**
         * 內部方法 
         * 返回回該線程局部變量的初始值
         * 初始化線程，每次get（）或者set（object）的時候會被調用。
         */
        protected Connection initialValue() {
            try {
                return DaoUtils.getConn();
            } catch (Exception e) {
                e.printStackTrace();
                return null;
            }
        }
    };
    private TranManager(){}
    public static  Connection getConn(){
        return tl.get();
    }
    /**
     * @return 開啟手動提交事務，
     * @false: 將sql命令交給應用程序管理 
     */
    public static void startTran(){
        try {
            tl.get().setAutoCommit(false);
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }
    /**
     * @return 回滾
     */
    public static void rollbackTran(){
        try {
            tl.get().rollback();
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }
    /**
     * @return 執行
     */
    public static void commitTran(){
        try {
            tl.get().commit();
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }
    /**
     * @return 關閉
     */
    public static void release(){
        try {
            tl.get().close();
            tl.remove();//map{tl:conn}
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }
    /*public void rollbackTran(Savepoint sp){
        try {
            conn.rollback(sp);
            conn.commit();
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }*/
}