[java] view plaincopyprint?

1. package com.test;  
2.   
3. public class TestNum {  
4.     // ①通过匿名内部类覆盖ThreadLocal的initialValue()方法，指定初始值  
5.     private static ThreadLocal<Integer> seqNum = new ThreadLocal<Integer>() {  
6.         public Integer initialValue() {  
7.             return 0;  
8.         }  
9.     };  
10.   
11.     // ②获取下一个序列值  
12.     public int getNextNum() {  
13.         seqNum.set(seqNum.get() + 1);  
14.         return seqNum.get();  
15.     }  
16.   
17.     public static void main(String[] args) {  
18.         TestNum sn = new TestNum();  
19.         // ③ 3个线程共享sn，各自产生序列号  
20.         TestClient t1 = new TestClient(sn);  
21.         TestClient t2 = new TestClient(sn);  
22.         TestClient t3 = new TestClient(sn);  
23.         t1.start();  
24.         t2.start();  
25.         t3.start();  
26.     }  
27.   
28.     private static class TestClient extends Thread {  
29.         private TestNum sn;  
30.   
31.         public TestClient(TestNum sn) {  
32.             this.sn = sn;  
33.         }  
34.   
35.         public void run() {  
36.             for (int i = 0; i < 3; i++) {  
37.                 // ④每个线程打出3个序列值  
38.                 System.out.println("thread[" + Thread.currentThread().getName() + "] --> sn["  
39.                          + sn.getNextNum() + "]");  
40.             }  
41.         }  
42.     }  
43. }  

[java] view plaincopyprint?

1. package com.test;  
2.   
3. import java.sql.Connection;  
4. import java.sql.SQLException;  
5. import java.sql.Statement;  
6.   
7. public class TestDao {  
8.     private Connection conn;// ①一个非线程安全的变量  
9.   
10.     public void addTopic() throws SQLException {  
11.         Statement stat = conn.createStatement();// ②引用非线程安全变量  
12.         // …  
13.     }  
14. }  

[java] view plaincopyprint?

1. package com.test;  
2.   
3. import java.sql.Connection;  
4. import java.sql.SQLException;  
5. import java.sql.Statement;  
6.   
7. public class TestDaoNew {  
8.     // ①使用ThreadLocal保存Connection变量  
9.     private static ThreadLocal<Connection> connThreadLocal = new ThreadLocal<Connection>();  
10.   
11.     public static Connection getConnection() {  
12.         // ②如果connThreadLocal没有本线程对应的Connection创建一个新的Connection，  
13.         // 并将其保存到线程本地变量中。  
14.         if (connThreadLocal.get() == null) {  
15.             Connection conn = getConnection();  
16.             connThreadLocal.set(conn);  
17.             return conn;  
18.         } else {  
19.             return connThreadLocal.get();// ③直接返回线程本地变量  
20.         }  
21.     }  
22.   
23.     public void addTopic() throws SQLException {  
24.         // ④从ThreadLocal中获取线程对应的Connection  
25.         Statement stat = getConnection().createStatement();  
26.     }  
27. }  

[java] view plaincopyprint?

1. package com.test;  
2.   
3. import java.sql.Connection;  
4. import java.sql.DriverManager;  
5. import java.sql.SQLException;  
6.   
7. public class ConnectionManager {  
8.   
9.     private static ThreadLocal<Connection> connectionHolder = new ThreadLocal<Connection>() {  
10.         @Override  
11.         protected Connection initialValue() {  
12.             Connection conn = null;  
13.             try {  
14.                 conn = DriverManager.getConnection(  
15.                         "jdbc:mysql://localhost:3306/test", "username",  
16.                         "password");  
17.             } catch (SQLException e) {  
18.                 e.printStackTrace();  
19.             }  
20.             return conn;  
21.         }  
22.     };  
23.   
24.     public static Connection getConnection() {  
25.         return connectionHolder.get();  
26.     }  
27.   
28.     public static void setConnection(Connection conn) {  
29.         connectionHolder.set(conn);  
30.     }  
31. }  

[java] view plaincopyprint?

1. /** 
2.     * Sets the current thread's copy of this thread-local variable 
3.     * to the specified value.  Most subclasses will have no need to 
4.     * override this method, relying solely on the {@link #initialValue} 
5.     * method to set the values of thread-locals. 
6.     * 
7.     * @param value the value to be stored in the current thread's copy of 
8.     *        this thread-local. 
9.     */  
10.    public void set(T value) {  
11.        Thread t = Thread.currentThread();  
12.        ThreadLocalMap map = getMap(t);  
13.        if (map != null)  
14.            map.set(this, value);  
15.        else  
16.            createMap(t, value);  
17.    }  

[java] view plaincopyprint?

1. /** 
2.  * Get the map associated with a ThreadLocal. Overridden in 
3.  * InheritableThreadLocal. 
4.  * 
5.  * @param  t the current thread 
6.  * @return the map 
7.  */  
8. ThreadLocalMap getMap(Thread t) {  
9.     return t.threadLocals;  
10. }  
11.   
12. /** 
13.  * Create the map associated with a ThreadLocal. Overridden in 
14.  * InheritableThreadLocal. 
15.  * 
16.  * @param t the current thread 
17.  * @param firstValue value for the initial entry of the map 
18.  * @param map the map to store. 
19.  */  
20. void createMap(Thread t, T firstValue) {  
21.     t.threadLocals = new ThreadLocalMap(this, firstValue);  
22. }  

[java] view plaincopyprint?

1. /** 
2.  * Returns the value in the current thread's copy of this 
3.  * thread-local variable.  If the variable has no value for the 
4.  * current thread, it is first initialized to the value returned 
5.  * by an invocation of the {@link #initialValue} method. 
6.  * 
7.  * @return the current thread's value of this thread-local 
8.  */  
9. public T get() {  
10.     Thread t = Thread.currentThread();  
11.     ThreadLocalMap map = getMap(t);  
12.     if (map != null) {  
13.         ThreadLocalMap.Entry e = map.getEntry(this);  
14.         if (e != null)  
15.             return (T)e.value;  
16.     }  
17.     return setInitialValue();  
18. }  

[java] view plaincopyprint?

1. /** 
2.     * Variant of set() to establish initialValue. Used instead 
3.     * of set() in case user has overridden the set() method. 
4.     * 
5.     * @return the initial value 
6.     */  
7.    private T setInitialValue() {  
8.        T value = initialValue();  
9.        Thread t = Thread.currentThread();  
10.        ThreadLocalMap map = getMap(t);  
11.        if (map != null)  
12.            map.set(this, value);  
13.        else  
14.            createMap(t, value);  
15.        return value;  
16.    }  

ConnectionManager.java

[java] view plaincopyprint?

1. package com.test;  
2.   
3. import java.sql.Connection;  
4. import java.sql.DriverManager;  
5. import java.sql.SQLException;  
6.   
7. public class ConnectionManager {  
8.   
9.     private static ThreadLocal<Connection> connectionHolder = new ThreadLocal<Connection>() {  
10.         @Override  
11.         protected Connection initialValue() {  
12.             Connection conn = null;  
13.             try {  
14.                 conn = DriverManager.getConnection(  
15.                         "jdbc:mysql://localhost:3306/test", "username",  
16.                         "password");  
17.             } catch (SQLException e) {  
18.                 e.printStackTrace();  
19.             }  
20.             return conn;  
21.         }  
22.     };  
23.   
24.     public static Connection getConnection() {  
25.         return connectionHolder.get();  
26.     }  
27.   
28.     public static void setConnection(Connection conn) {  
29.         connectionHolder.set(conn);  
30.     }  
31. }