gpt4 book ai didi

java - ThreadLocals 在异步支持的过滤器中启动是线程安全的吗

转载 作者:行者123 更新时间:2023-11-30 07:36:40 25 4
gpt4 key购买 nike

在 JSR 315 中添加了对 servlet 和过滤器的异步支持。在这样的过滤器中创建的 ThreadLocal 线程安全吗?

<filter>
<filter-name>ResourceFilter</filter-name>
<filter-class>com.app.filter.ResourceFilter</filter-class>
<async-supported>true</async-supported>
</filter>

过滤器

public class ResourceFilter implements Filter  {



private final Logger log = LoggerFactory.getLogger(getClass());

@Override
public void init(FilterConfig filterConfig) throws ServletException {}

@Override
public void doFilter(ServletRequest request, ServletResponse response,
FilterChain chain) throws IOException, ServletException {

try{
String uri = WebUtilityHelper.getURI(request);
boolean isAResource = WebUtilityHelper.isAResource(uri);
ThreadLocalUtil.setIsResource(isAResource);
log.trace("URI: {}, isAResource? {}", uri, isAResource);
} finally {
chain.doFilter(request, response);
}
}

@Override
public void destroy() {}

}

以及util的相关部分。我在此维护多个 hibernate session 。无需详细说明,这是支持应用程序级分片解决方案。多个数据源共享在单独的类加载器下加载的实体...由不同的 session 工厂管理。

public class ThreadLocalUtil {

/* Contant static names */

private static final String HIBERNATE_ASYNC_SESSION = "hibernateAsyncSession";
private static final String HIBERNATE_GLOBAL_SESSION = "hibernateGlobalSession";



private static final String IS_RESOURCE = "isResource";

/* The Constant THREAD_VARIABLES */
private static final ThreadLocal<ThreadVariables> THREAD_VARIABLES = new ThreadLocal<ThreadVariables>() {

/**
* @see java.lang.ThreadLocal#initialValue()
*/
@Override
protected ThreadVariables initialValue() {
return new ThreadVariables();
}
};


public static Object get(String name) {
return getThreadVariable(name);
}

/**
* Gets the thread variable.
*
* @param name
* the name
* @return the thread variable
*/
public static Object getThreadVariable(String name) {
return THREAD_VARIABLES.get().get(name);
} /**
* Sets the thread variable.
*
* @param name
* the name
* @param value
* the value
*/
public static synchronized void setThreadVariable(String name,
Object value) {
THREAD_VARIABLES.get().put(name, value);
}

/**
* Destroy.
*/
public static void destroy() {
closeAllHibernateSessions();
THREAD_VARIABLES.remove();
}

public static void remove(String name) {
THREAD_VARIABLES.get().remove(name);
}}

我认为我真正想问的是Servlet 3.0 规范 2.3.3.4 http://download.oracle.com/otn-pub/jcp/servlet-3.0-fr-eval-oth-JSpec/servlet-3_0-final-spec.pdf?AuthParam=1455121502_a9b513ab9b8fc5ac5a82d0518e88f7ac

最佳答案

就 ThreadLocal 是否线程安全而言,异步架构与同步架构没有什么不同。只要引用不泄露给其他线程,那么它就是安全的。

在你的代码片段中,即。假设(我无法判断)ThreadLocalUtil 的实现没有做任何危险的事情。

顺便说一句 - 在异步模式下运行过滤器链的多个容器存在一些限制 - 请参阅 this on Github

关于java - ThreadLocals 在异步支持的过滤器中启动是线程安全的吗,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/35303173/

25 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com