美文网首页
线程封闭

线程封闭

作者: 三不猴子 | 来源:发表于2019-05-09 22:11 被阅读0次

    我们可以通过把对象设计成不可变对象来躲避并发,我们还可以通过使用线程封闭来实现线程安全,所谓线程封闭

    就是将数据都封装到一个线程里,不让其他线程访问。

    • Ad-hoc 线程封闭程序控制实现,比较脆弱,尽量少用
    • 堆栈封闭:局部变量,无并发问题,在项目中使用最多,简单说就是局部变量,方法的变量都拷贝到线程的堆栈中,只有这个线程能访问到。尽量少使用全局变量(变量不是常量)
    • ThreadLocal线程封闭:比较好的封闭方法

    ThreadLocal维护的是一个map 这个map是线程的名称多为key 我们所有封闭的值作为value。
    我们做使用Filter做登录操作都做过,我们现在来使用ThreadLoad来存储一下用户信息。

    public class RequestHolder {
    
        private final static ThreadLocal<Long> requestHolder = new ThreadLocal<>();
    
        public static void add(Long id) {
            requestHolder.set(id);
        }
    
        public static Long getId() {
            return requestHolder.get();
        }
    
        public static void remove() {
            requestHolder.remove();
        }
    }
    

    声明一个ThreadLoad对象用来存储ThreadLoad信息。

    @Slf4j
    public class HttpFilter implements Filter {
    
        @Override
        public void init(FilterConfig filterConfig) throws ServletException {
    
        }
    
        @Override
        public void doFilter(ServletRequest servletRequest, ServletResponse servletResponse, FilterChain filterChain) throws IOException, ServletException {
            HttpServletRequest request = (HttpServletRequest) servletRequest;
            log.info("do filter, {}, {}", Thread.currentThread().getId(), request.getServletPath());
            RequestHolder.add(Thread.currentThread().getId());
            filterChain.doFilter(servletRequest, servletResponse);
        }
    
        @Override
        public void destroy() {
    
        }
    
    
    @Slf4j
    public class HttpInterceptor extends HandlerInterceptorAdapter {
    
        @Override
        public boolean preHandle(HttpServletRequest request, HttpServletResponse response, Object handler) throws Exception {
            log.info("preHandle");
            return true;
        }
    
        @Override
        public void afterCompletion(HttpServletRequest request, HttpServletResponse response, Object handler, Exception ex) throws Exception {
            RequestHolder.remove();
            log.info("afterCompletion");
            return;
        }
    }
    

    定义filter的内容,我们在filter中将线程id加入到ThreadLoad中,然后在controller中获取,看看能不能获取的到。在线程执行完之后将ThreadLoad中的数据清空防止内存溢出。

    @Controller
    @RequestMapping("/threadLocal")
    public class ThreadLocalController {
    
        @RequestMapping("/test")
        @ResponseBody
        public Long test() {
            return RequestHolder.getId();
        }
    }
    
    

    最后我们用postman测试发现打印了线程id,ThreadLoad中变量值只要是一个线程中不管在哪个类中都是共享的。

    相关文章

      网友评论

          本文标题:线程封闭

          本文链接:https://www.haomeiwen.com/subject/tbhnoqtx.html