我使用 InheritableThreadlocal
和 HashMap
来存储我的所有线程局部变量。
class MyThreadLocalMap {
private final static ThreadLocal<HashMap<String, Object>> THREAD_VARIABLES = new InheritableThreadLocal<HashMap<String, Object>>() {
@Override
protected HashMap<String, Object> initialValue() {
return new HashMap<>();
}
};
public static Object get(String name) {
return THREAD_VARIABLES.get().get(name);
}
public static Object set(String name, Object value) {
Object currentValue = get(name);
THREAD_VARIABLES.get().put(name, value);
return currentValue;
}
}
这一切都很好,直到昨天出现了一个奇怪的错误。
我正在使用 tomcat 服务器来运行我的 Web 应用程序。我使用 ScheduledThreadPoolExecutor
创建线程池并在多个线程中运行任务。我的代码的简短形式看起来与此类似。
MyThreadLocalMap.set("MyKey", 1);
....
....
Object obj = MyThreadLocalMap.get("MyKey");
if(!Integer.valueOf(1).equals(obj))
throw new Exception("threadlocal mismatch!");
....
....
MyThreadLocalMap.set("MyKey", null);
上面的代码将在多个线程中执行,并且由于我使用线程池,因此相同的线程将被重用。
奇怪的是,在大约 5 个线程成功执行之后,其中一个线程抛出了“threadlocal Mismatch”异常!
我的主要怀疑是使用 InheritableThreadLocal(它因内存泄漏而臭名昭著)
我尝试并重试在开发服务器中重现该问题,但未能成功。而且我不想冒险在生产服务器中测试这个。
最佳答案
您的 map 在父线程中实例化。 InheritedThreadLocal 值被“取下”到子线程。
虽然多个子线程可能并行执行,特别是。如图所示,一个线程可以将“MyKey”设置为 null,而另一个子线程正在读取它。
所以这是一个真正的问题。您应该在设置和读取之间同步代码。或者使用普通的ThreadLocal。
顺便说一句。您应该同步对 map 的访问。
关于java - java中InheritableThreadlocal值自动改变,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/48822169/