Spring中ThreadLocal的解析

void set(Object value)

ublic Object get()

public void remove()

protected Object initialValue()

   public class SimpleThreadLocal {  
                  
                private Map valueMap = Collections.synchronizedMap(new HashMap());  
      
                public void set(Object newValue) {  
                    valueMap.put(Thread.currentThread(), newValue); //①键为线程对象，值为本线程的变量副本  
                }  
      
                public Object get() {  
                    Thread currentThread = Thread.currentThread();  
                    Object o = valueMap.get(currentThread);     //②返回本线程对应的变量  
          
                    if (o == null && !valueMap.containsKey(currentThread)) {//③如果在Map中不存在，放到Map中保存起来。  
                        o = initialValue();  
                        valueMap.put(currentThread, o);  
                    }  
                      
                    return o;  
                }  
      
                public void remove() {  
                    valueMap.remove(Thread.currentThread());  
                }  
      
                public Object initialValue() {  
                    return null;  
                }  
      
       }  

package threadLocalDemo;
    
        public class SequenceNumber{
 
              //①通过匿名内部类覆盖ThreadLocal的initialValue()方法，指定初始值--初始化
            //ThreadLocal能够保证每个线程在使用该变量的时候都拥有一份独立的变量。Map实现
            private static ThreadLocal<Integer> seqNum =new ThreadLocal<Integer>(){
                   public Integer initialValue() {
                       return 0; //初始化时候为0
                   }        
              };
        
            //②获取下一个序列值    
            public int getNextNum(){    
               seqNum.set(seqNum.get()+ 1);
               return seqNum.get();
            }
        
            public static void main(String[] args){
    
               SequenceNumber sn = new SequenceNumber();
    
               // ③ 3个线程共享sn，各自产生序列号    
               TestClient t1 = new TestClient(sn);
               TestClient t2 = new TestClient(sn);    
               TestClient t3 = new TestClient(sn);
    
               t1.start();    
               t2.start();    
               t3.start();    
            }
        
                private static class TestClient extends Thread{    
                   private SequenceNumber sn;
        
                   public TestClient(SequenceNumber sn) {    
                       this.sn= sn;
                   }
        
                   public void run() {    
                       for (int i= 0; i < 3;i++) {    
                           //④每个线程打出3个序列值    
                           System.out.println("thread[" + Thread.currentThread().getName()+"]sn[" +sn.getNextNum() + "]");    
                       }    
                   }
        
                }
    
        }

public class TopicDao{
    
        private Connection conn;//①一个非线程安全的变量
    
        public void addTopic(){
            Statement stat = conn.createStatement();//②引用非线程安全变量
        
            …
        }
    
    }

public class sqlConnection {
    
            //①使用ThreadLocal保存Connection变量
            private static ThreadLocal<Connection> connThreadLocal = new ThreadLocal<Connection>();
    
            public static Connection getConnection() {
 
               //②如果connThreadLocal没有本线程对应的Connection,创建一个新的Connection,并将其保存到线程本地变量中。
                //如果线程变量中存在对应的Connection,那么就取出来
               if (connThreadLocal.get()== null){
                   Connection conn = getConnection();
                   connThreadLocal.set(conn);
                   return conn;    
               }else {    //③直接返回线程本地变量
                   return connThreadLocal.get();          
               }
    
            }
    
            public void addTopic() {
    
               // ④从ThreadLocal中获取线程对应的Connection,每个线程都保存一份独立的变量    
               try {    
                   Statement stat = getConnection().createStatement();    
               }catch (SQLException e) {    
                   e.printStackTrace();    
               }
    
            }
    
        }