在Spring中@transactional
注解,开启事务的时候,在使用方法调用的时候形成方法依次向下调用,
当最后一个方法支持事务的时候,调用connection从前面拿过来,但是connection在spring中是注入进来的,它们用的connection必须是同一个,但是不能使用static,因为在多线程下是不安全的,所以这里就使用成员变量放到了ThreadLocal里。 一个线程向ThreadLocal中放入对象,其他线程是取不出来这个对象的,也就是说ThreadLocal对线程有一个绑定和天然隔离的作用。 代码说明:
package com.css.apps.base.dict.service;
import com.sun.syndication.feed.atom.Person;
import java.sql.Statement;
import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.CopyOnWriteArrayList;
import java.util.concurrent.TimeUnit;
/**
* zt
* 2021/6/17
* 14:35
*/
public class TestDemo {
static ThreadLocal<Person> tl = new ThreadLocal<>();
public static void main(String[] args) {
new Thread(new Runnable() {
@Override
public void run() {
try {
TimeUnit.SECONDS.sleep(2);
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println(tl.get());
}
}).start();
new Thread(new Runnable() {
@Override
public void run() {
try {
TimeUnit.SECONDS.sleep(1);
} catch (InterruptedException e) {
e.printStackTrace();
}
tl.set(new Person());
}
}).start();
}
static class Person{
String name = "zhangsan";
}
}
两个线程从ThreadLocal中拿对象,第二个线程放完,第一个对象正常来讲是可以拿到这个对象的,但是因为这个对象是放在ThreadLocal中的,对每个线程来讲它都是绑定单一线程的,看一下原码
也就是说,ThreadLocal底层就是一个Map,然后key就是这个ThreadLocal也就是前代码中的tl
,value就是我们自己给的这值也就是前代码中的person
。然后我们再看这个Map是什么?
点进去可以看到,这个map就是Thread类里面的一个成员方法,
也就是说,每次我们new一个Thread,就有这个Thread的自己的长成员变量ThreadLocalMap threadLocals,key和value就在这里。ThreadLocal的底层就是这个map。 如果再往下看这个map是什么
看到这个map里面其实就是entry,然后entry继承了这个弱引用,K就是tl,value就是person。
那么问题来了,在内存不足的时候,垃圾回收器会回收那个弱引用,但是value上面的内存却是依然被占用的
。虽然ThreadLocal原码中有自己的get,set方法去清理key为null的这块内存,但是也有一些线程是一直不间断执行的(比如说服务器线程365天不间断的),所以就需要我们在使用完ThreadLocal的时候执行remove去回收这份内存。
当使用线程池的时候,如果没有清理里面线程的ThreadLocal就还回来了,甚至key相同的ThreadLocal会互相替换,也会造成内存泄漏或是结果混乱等问题