- 浏览: 2114508 次
- 性别:
- 来自: 北京
文章分类
最新评论
-
sunzeshan:
找了很久,用了这个插件解决问题啦。谢谢
eclipse jetty debug source not found -
xiaosong0112:
您好,请问为什么要这样设置呢,原理是什么?在网上很多转帖都没有 ...
maven的jetty插件提示No Transaction manager found导致启动慢的解决方法 -
eimhee:
tjzx 写道畅搜谷歌:http://dian168.cc/打 ...
Google 镜像站搜集 -
tjzx:
畅搜谷歌:http://dian168.cc/打开的是“最火源 ...
Google 镜像站搜集 -
eimhee:
finallygo 写道你这属于"头痛医头脚痛医脚& ...
解决linux下too many file问题
ThreadLocal 引起的内存泄露
- 博客分类:
- JAVA
最近在用LOADRUNNER做性能测试,
运行几个小时后,内存一直增加, 最后出现了内存OutMemory问题。
已知的一个BUG:
http://java.net/jira/browse/JAXB-844
JAXB 2.1.15 有问题类Coordinator
/* * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS HEADER. * * Copyright 1997-2007 Sun Microsystems, Inc. All rights reserved. * * The contents of this file are subject to the terms of either the GNU * General Public License Version 2 only ("GPL") or the Common Development * and Distribution License("CDDL") (collectively, the "License"). You * may not use this file except in compliance with the License. You can obtain * a copy of the License at https://glassfish.dev.java.net/public/CDDL+GPL.html * or glassfish/bootstrap/legal/LICENSE.txt. See the License for the specific * language governing permissions and limitations under the License. * * When distributing the software, include this License Header Notice in each * file and include the License file at glassfish/bootstrap/legal/LICENSE.txt. * Sun designates this particular file as subject to the "Classpath" exception * as provided by Sun in the GPL Version 2 section of the License file that * accompanied this code. If applicable, add the following below the License * Header, with the fields enclosed by brackets [] replaced by your own * identifying information: "Portions Copyrighted [year] * [name of copyright owner]" * * Contributor(s): * * If you wish your version of this file to be governed by only the CDDL or * only the GPL Version 2, indicate your decision by adding "[Contributor] * elects to include this software in this distribution under the [CDDL or GPL * Version 2] license." If you don't indicate a single choice of license, a * recipient has the option to distribute your version of this file under * either the CDDL, the GPL Version 2 or to extend the choice of license to * its licensees as provided above. However, if you add GPL Version 2 code * and therefore, elected the GPL Version 2 license, then the option applies * only if the new code is made subject to such option by the copyright * holder. */ package com.sun.xml.bind.v2.runtime; import java.util.HashMap; import javax.xml.bind.ValidationEvent; import javax.xml.bind.ValidationEventHandler; import javax.xml.bind.ValidationEventLocator; import javax.xml.bind.annotation.adapters.XmlAdapter; import javax.xml.bind.helpers.ValidationEventImpl; import com.sun.xml.bind.v2.ClassFactory; import com.sun.xml.bind.v2.runtime.unmarshaller.UnmarshallingContext; import org.xml.sax.ErrorHandler; import org.xml.sax.SAXException; import org.xml.sax.SAXParseException; /** * Object that coordinates the marshalling/unmarshalling. * * <p> * This class takes care of the logic that allows code to obtain * {@link UnmarshallingContext} and {@link XMLSerializer} instances * during the unmarshalling/marshalling. * * <p> * This is done by using a {@link ThreadLocal}. Therefore one unmarshalling/marshalling * episode has to be done from the beginning till end by the same thread. * (Note that the same {@link Coordinator} can be then used by a different thread * for an entirely different episode.) * * This class also maintains the user-configured instances of {@link XmlAdapter}s. * * <p> * This class implements {@link ErrorHandler} and propages erros to this object * as the {@link ValidationEventHandler}, which will be implemented in a derived class. * * @author Kohsuke Kawaguchi */ public abstract class Coordinator implements ErrorHandler, ValidationEventHandler { private final HashMap<Class<? extends XmlAdapter>,XmlAdapter> adapters = new HashMap<Class<? extends XmlAdapter>,XmlAdapter>(); public final XmlAdapter putAdapter(Class<? extends XmlAdapter> c, XmlAdapter a) { if(a==null) return adapters.remove(c); else return adapters.put(c,a); } /** * Gets the instance of the adapter. * * @return * always non-null. */ public final <T extends XmlAdapter> T getAdapter(Class<T> key) { T v = key.cast(adapters.get(key)); if(v==null) { v = ClassFactory.create(key); putAdapter(key,v); } return v; } public <T extends XmlAdapter> boolean containsAdapter(Class<T> type) { return adapters.containsKey(type); } /** * The {@link Coordinator} in charge before this {@link Coordinator}. */ private Coordinator old; /** * A 'pointer' to a {@link Coordinator} that keeps track of the currently active {@link Coordinator}. * Having this improves the runtime performance. */ private Coordinator[] table; /** * When we set {@link #table} to null, record who did it. * This is for trouble-shooting a possible concurrency issue reported at: * http://forums.java.net/jive/thread.jspa?threadID=15132 */ public Exception guyWhoSetTheTableToNull; /** * Associates this {@link Coordinator} with the current thread. * Should be called at the very beginning of the episode. */ protected final void setThreadAffinity() { table = activeTable.get(); assert table!=null; } /** * Dis-associate this {@link Coordinator} with the current thread. * Sohuld be called at the end of the episode to avoid memory leak. */ protected final void resetThreadAffinity() { if(debugTableNPE) guyWhoSetTheTableToNull = new Exception(); // remember that we set it to null table = null; } /** * Called whenever an execution flow enters the realm of this {@link Coordinator}. */ protected final void pushCoordinator() { old = table[0]; table[0] = this; } /** * Called whenever an execution flow exits the realm of this {@link Coordinator}. */ protected final void popCoordinator() { assert table[0]==this; table[0] = old; old = null; // avoid memory leak } public static Coordinator _getInstance() { return activeTable.get()[0]; } // this much is necessary to avoid calling get and set twice when we push. private static final ThreadLocal<Coordinator[]> activeTable = new ThreadLocal<Coordinator[]>() { public Coordinator[] initialValue() { return new Coordinator[1]; } }; // // // ErrorHandler implementation // // /** * Gets the current location. Used for reporting the error source location. */ protected abstract ValidationEventLocator getLocation(); public final void error(SAXParseException exception) throws SAXException { propagateEvent( ValidationEvent.ERROR, exception ); } public final void warning(SAXParseException exception) throws SAXException { propagateEvent( ValidationEvent.WARNING, exception ); } public final void fatalError(SAXParseException exception) throws SAXException { propagateEvent( ValidationEvent.FATAL_ERROR, exception ); } private void propagateEvent( int severity, SAXParseException saxException ) throws SAXException { ValidationEventImpl ve = new ValidationEventImpl( severity, saxException.getMessage(), getLocation() ); Exception e = saxException.getException(); if( e != null ) { ve.setLinkedException( e ); } else { ve.setLinkedException( saxException ); } // call the client's event handler. If it returns false, then bail-out // and terminate the unmarshal operation. boolean result = handleEvent( ve ); if( ! result ) { // bail-out of the parse with a SAX exception, but convert it into // an UnmarshalException back in in the AbstractUnmarshaller throw saxException; } } public static boolean debugTableNPE; static { try { debugTableNPE = Boolean.getBoolean(Coordinator.class.getName()+".debugTableNPE"); } catch (SecurityException t) { } } }
变量adapters一直没有进行REMOVE操作
JAXB(V2.2.25)修复后的代码如下:
/* * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS HEADER. * * Copyright (c) 1997-2011 Oracle and/or its affiliates. All rights reserved. * * The contents of this file are subject to the terms of either the GNU * General Public License Version 2 only ("GPL") or the Common Development * and Distribution License("CDDL") (collectively, the "License"). You * may not use this file except in compliance with the License. You can * obtain a copy of the License at * https://glassfish.dev.java.net/public/CDDL+GPL_1_1.html * or packager/legal/LICENSE.txt. See the License for the specific * language governing permissions and limitations under the License. * * When distributing the software, include this License Header Notice in each * file and include the License file at packager/legal/LICENSE.txt. * * GPL Classpath Exception: * Oracle designates this particular file as subject to the "Classpath" * exception as provided by Oracle in the GPL Version 2 section of the License * file that accompanied this code. * * Modifications: * If applicable, add the following below the License Header, with the fields * enclosed by brackets [] replaced by your own identifying information: * "Portions Copyright [year] [name of copyright owner]" * * Contributor(s): * If you wish your version of this file to be governed by only the CDDL or * only the GPL Version 2, indicate your decision by adding "[Contributor] * elects to include this software in this distribution under the [CDDL or GPL * Version 2] license." If you don't indicate a single choice of license, a * recipient has the option to distribute your version of this file under * either the CDDL, the GPL Version 2 or to extend the choice of license to * its licensees as provided above. However, if you add GPL Version 2 code * and therefore, elected the GPL Version 2 license, then the option applies * only if the new code is made subject to such option by the copyright * holder. */ package com.sun.xml.bind.v2.runtime; import java.util.HashMap; import javax.xml.bind.ValidationEvent; import javax.xml.bind.ValidationEventHandler; import javax.xml.bind.ValidationEventLocator; import javax.xml.bind.annotation.adapters.XmlAdapter; import javax.xml.bind.helpers.ValidationEventImpl; import com.sun.xml.bind.v2.ClassFactory; import com.sun.xml.bind.v2.runtime.unmarshaller.UnmarshallingContext; import org.xml.sax.ErrorHandler; import org.xml.sax.SAXException; import org.xml.sax.SAXParseException; /** * Object that coordinates the marshalling/unmarshalling. * * <p> * This class takes care of the logic that allows code to obtain * {@link UnmarshallingContext} and {@link XMLSerializer} instances * during the unmarshalling/marshalling. * * <p> * This is done by using a {@link ThreadLocal}. Therefore one unmarshalling/marshalling * episode has to be done from the beginning till end by the same thread. * (Note that the same {@link Coordinator} can be then used by a different thread * for an entirely different episode.) * * This class also maintains the user-configured instances of {@link XmlAdapter}s. * * <p> * This class implements {@link ErrorHandler} and propages erros to this object * as the {@link ValidationEventHandler}, which will be implemented in a derived class. * * @author Kohsuke Kawaguchi */ public abstract class Coordinator implements ErrorHandler, ValidationEventHandler { private final HashMap<Class<? extends XmlAdapter>,XmlAdapter> adapters = new HashMap<Class<? extends XmlAdapter>,XmlAdapter>(); public final XmlAdapter putAdapter(Class<? extends XmlAdapter> c, XmlAdapter a) { if(a==null) return adapters.remove(c); else return adapters.put(c,a); } /** * Gets the instance of the adapter. * * @return * always non-null. */ public final <T extends XmlAdapter> T getAdapter(Class<T> key) { T v = key.cast(adapters.get(key)); if(v==null) { v = ClassFactory.create(key); putAdapter(key,v); } return v; } public <T extends XmlAdapter> boolean containsAdapter(Class<T> type) { return adapters.containsKey(type); } /** * The {@link Coordinator} in charge before this {@link Coordinator}. */ private Object old; /** * A 'pointer' to a {@link Coordinator} that keeps track of the currently active {@link Coordinator}. * Having this improves the runtime performance. */ private Object[] table; /** * When we set {@link #table} to null, record who did it. * This is for trouble-shooting a possible concurrency issue reported at: * http://forums.java.net/jive/thread.jspa?threadID=15132 */ public Exception guyWhoSetTheTableToNull; /** * Associates this {@link Coordinator} with the current thread. * Should be called at the very beginning of the episode. */ protected final void setThreadAffinity() { table = activeTable.get(); assert table!=null; } /** * Dis-associate this {@link Coordinator} with the current thread. * Sohuld be called at the end of the episode to avoid memory leak. */ protected final void resetThreadAffinity() { if (activeTable != null) { activeTable.remove(); } if(debugTableNPE) guyWhoSetTheTableToNull = new Exception(); // remember that we set it to null table = null; } /** * Called whenever an execution flow enters the realm of this {@link Coordinator}. */ protected final void pushCoordinator() { old = table[0]; table[0] = this; } /** * Called whenever an execution flow exits the realm of this {@link Coordinator}. */ protected final void popCoordinator() { assert table[0]==this; table[0] = old; old = null; // avoid memory leak } public static Coordinator _getInstance() { return (Coordinator) activeTable.get()[0]; } // this much is necessary to avoid calling get and set twice when we push. private static final ThreadLocal<Object[]> activeTable = new ThreadLocal<Object[]>() { @Override public Object[] initialValue() { return new Object[1]; } }; // // // ErrorHandler implementation // // /** * Gets the current location. Used for reporting the error source location. */ protected abstract ValidationEventLocator getLocation(); public final void error(SAXParseException exception) throws SAXException { propagateEvent( ValidationEvent.ERROR, exception ); } public final void warning(SAXParseException exception) throws SAXException { propagateEvent( ValidationEvent.WARNING, exception ); } public final void fatalError(SAXParseException exception) throws SAXException { propagateEvent( ValidationEvent.FATAL_ERROR, exception ); } private void propagateEvent( int severity, SAXParseException saxException ) throws SAXException { ValidationEventImpl ve = new ValidationEventImpl( severity, saxException.getMessage(), getLocation() ); Exception e = saxException.getException(); if( e != null ) { ve.setLinkedException( e ); } else { ve.setLinkedException( saxException ); } // call the client's event handler. If it returns false, then bail-out // and terminate the unmarshal operation. boolean result = handleEvent( ve ); if( ! result ) { // bail-out of the parse with a SAX exception, but convert it into // an UnmarshalException back in in the AbstractUnmarshaller throw saxException; } } public static boolean debugTableNPE; static { try { debugTableNPE = Boolean.getBoolean(Coordinator.class.getName()+".debugTableNPE"); } catch (SecurityException t) { } } }
主要是加了下面这个代码修复了内存泄露问题
/** * Dis-associate this {@link Coordinator} with the current thread. * Sohuld be called at the end of the episode to avoid memory leak. */ protected final void resetThreadAffinity() { if (activeTable != null) { activeTable.remove(); } if(debugTableNPE) guyWhoSetTheTableToNull = new Exception(); // remember that we set it to null table = null; }
所以由THREADLOCAL创建的变量一定要进行REMOVE操作
原文:http://extjs2.iteye.com/admin/blogs/1701172
评论
4 楼
xiaoguang0904
2013-03-26
eimhee 写道
xiaoguang0904 写道
最新的jaxb里面这个方法也没有改!
最新的JAXB已经没这个问题吧
最新的的确没这个问题了。
3 楼
eimhee
2013-03-12
xiaoguang0904 写道
最新的jaxb里面这个方法也没有改!
最新的JAXB已经没这个问题吧
2 楼
xiaoguang0904
2013-03-11
最新的jaxb里面这个方法也没有改!
1 楼
xiaoguang0904
2013-03-11
jaxb 有 2.2.25吗?
发表评论
-
MySQLNonTransientConnectionException: No operations allowed
2015-05-19 16:47 2266最近在调试会发现“ No operations allow ... -
mysql 执行计划优化
2013-04-07 17:46 1486一条简单的SQL 语句竟花了15.87 sec, ... -
lucene 反向索引原理
2012-07-20 12:47 1948lucene是一个高性能的全文搜索工具, 使用反向索引结构。 ... -
tomcat7在UBUNTU上自动启动
2012-06-11 12:55 2715为了让tomcat自动启动当电脑重起时, 你必须添加一个脚本, ... -
hadoop中的Writable分析
2012-06-07 11:27 3337hadoop 要使一个类能序例化, 要实现Writabl ... -
在UBUNTU安装NUTCH(十个简单的步骤)
2012-06-06 17:32 3956下面十个步骤能安装Nutch, 并且能爬行你的网站, 创建你自 ... -
深入Lucene的索引文件
2012-02-01 16:50 6754Lucene的索引里面存了些什么,如何存放的,也即Luc ... -
EasyMock and IllegalStateException
2012-01-31 15:09 1303When writing a portlet and tryi ... -
Java Enum的原理
2011-05-03 09:19 1777Java Enum 类型的语法结构尽管和 java 类的语法不 ... -
用JAXB从对象生成XML
2011-04-26 08:54 2924import java.io.FileOutputStream ... -
jdk6 WebService入门
2011-03-10 23:04 3294一、 Web Services简介 ... -
dom4j处理超大XML
2010-12-26 23:35 4772英文原文 : http://dom4j.sourceforge ... -
httpclient3 自动登陆淘宝, 开心网
2010-11-09 22:09 9925前提:需要用到的java包 commons-httpclien ... -
Lucene实时索引构建
2010-11-06 23:11 7376Lucene可以增量的添加一 ... -
分享Java并发最佳书籍Java Concurrency in Practice Java并发最佳书籍 下载
2010-10-21 08:31 13355好久没有上来更新过了,最近在学习线程池实现,参考了 Tomc ... -
Spring Hibernate3 配置 C3P0
2010-10-15 00:31 7499由于Hibernate3不推荐使用DBCP, 所以把连接池换成 ... -
将依赖包加入到本地maven库
2010-07-22 16:47 2837要将依赖包加入到本地maven库 mvn instal ... -
Maven Dependency设置,详解!
2010-07-21 17:08 2458用了Maven,所需的JAR包 ... -
Inner Join with hibernate and HQL
2010-07-18 12:24 2111String queryStri ... -
ORACLE 分组 排序出前面最大的N行
2010-07-02 09:18 1599select custid,carid,Cunote,INV ...
相关推荐
问题背景在 Tomcat 中,下面的代码都在 webapp 内,会导致 WebappClassLoaderWebappClassLoader 泄漏,无法被回收。
ThreadLocal中内存泄漏和数据丢失问题的问题浅析及解决方案.docx
04、导致JVM内存泄露的ThreadLocal详解_ev04、导致JVM内存泄露的ThreadLocal详解_ev04、导致JVM内存泄露的ThreadLocal详解_ev04、导致JVM内存泄露的ThreadLocal详解_ev04、导致JVM内存泄露的ThreadLocal详解_ev04、...
一篇文章我们来分析一个Java中ThreadLocal内存泄露的案例。分析问题的过程比结果更重要,理论结合实际才能彻底分析出内存泄漏的原因。
主要介绍了ThreadLocal原理及内存泄漏原因,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
NULL 博文链接:https://liuinsect.iteye.com/blog/1827012
导致JVM内存泄露的ThreadLocal详解 为什么要有ThreadLocal ThreadLocal的使用 实现解析 引发的内存泄漏分析 错误使用ThreadLocal导致 线程不安全分析
JVM的基础和调优【JMM 内存结构 GC OOM 性能调优 ThreadLocal】 内存泄露:是指程序在申请内存后,无法释放已申请的内存空间就造成了内存泄露, 一次的内存泄露似乎不会有大的影响,但是内存泄露堆积的后果就是内存...
ThreadLocal入门教程。 讲解了线程安全和ThreadLocal的使用的基本知识。
ThreadLocal
详解java底层实现原理,ThreadLocal底层实现的数据结构,为什么不会导致内存泄露
理解ThreadLocal 理解ThreadLocal 理解ThreadLocal 理解ThreadLocal
ThreadLocal应用示例及理解,这个写了相关的示例,可以参考一下。
学习ThreadLocal,了解其中的原理,以及学习其中的优点!避免坑点!!
通过一个Demo来简要介绍下ThreadLocal和ClassLoader导致内存泄露最终OutOfMemory的场景。下面通过示例代码给大家分享Java内存泄露的相关知识,感兴趣的朋友一起看看吧
正确理解ThreadLocal.pdf
文本来自StackOverflow问答网站的一个热门讨论:如何用Java编写一段会发生内存泄露的代码。... 该类分配了大块内存(比如new byte[1000000]),在某个静态变量存储一个强引用,然后在ThreadLocal中存储它自身的引用
DbUTils中用ThreadLocal类