[Java]ThreadLocal详解

标签：java   线程安全   

• void set(Object value)
   设置当前线程的线程局部变量的值；
• public Object get() 
   该方法返回当前线程所对应的线程局部变量；
• public void remove()
   将当前线程局部变量的值删除，目的是为了减少内存的占用，该方法是JDK 5.0新增的方法。需要指出的是，当线程结束后，对应该线程的局部变量将自动被垃圾回收，所以显式调用该方法清除线程的局部变量并不是必须的操作，但它可以加快内存回收的速度；
• protected Object initialValue()
   返回该线程局部变量的初始值，该方法是一个protected的方法，显然是为了让子类覆盖而设计的。这个方法是一个延迟调用方法，在线程第1次调用get()或set(Object)时才执行，并且仅执行1次。ThreadLocal中的默认实现直接返回一个null。 

Java代码  

1. public class SimpleThreadLocal {  
2.     private Map valueMap = Collections.synchronizedMap(new HashMap());  
3.     public void set(Object newValue) {  
4.                 //①键为线程对象，值为本线程的变量副本  
5.         valueMap.put(Thread.currentThread(), newValue);  
6.     }  
7.     public Object get() {  
8.         Thread currentThread = Thread.currentThread();  
9.   
10.                 //②返回本线程对应的变量  
11.         Object o = valueMap.get(currentThread);   
12.                   
13.                 //③如果在Map中不存在，放到Map中保存起来  
14.                if (o == null && !valueMap.containsKey(currentThread)) {  
15.             o = initialValue();  
16.             valueMap.put(currentThread, o);  
17.         }  
18.         return o;  
19.     }  
20.     public void remove() {  
21.         valueMap.remove(Thread.currentThread());  
22.     }  
23.     public Object initialValue() {  
24.         return null;  
25.     }  
26. }  

Java代码  

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

Java代码  

1. public class TopicDao {  
2.    //①一个非线程安全的变量  
3.    private Connection conn;   
4.    public void addTopic(){  
5.         //②引用非线程安全变量  
6.        Statement stat = conn.createStatement();  
7.        …  
8.    }  
9. }  

Java代码  

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

[Java]ThreadLocal详解

标签：java   线程安全   

原文地址：http://blog.csdn.net/erlib/article/details/49148911