博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
线程封闭
阅读量:6257 次
发布时间:2019-06-22

本文共 2188 字,大约阅读时间需要 7 分钟。

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

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

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

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

public class RequestHolder {    private final static ThreadLocal
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信息。

@Slf4jpublic 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() {    }复制代码
@Slf4jpublic 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中变量值只要是一个线程中不管在哪个类中都是共享的。

转载地址:http://rtasa.baihongyu.com/

你可能感兴趣的文章
十周三次课(5月29日)
查看>>
使用MaxCompute Java SDK 执行任务卡住了,怎么办?
查看>>
Pick!闲鱼亿级商品库中的秒级实时选品
查看>>
五四,阿里巴巴新青年了解下?
查看>>
【博客话题】呼叫中心系统的那些事
查看>>
我的友情链接
查看>>
(一)指南一、初学者指南1、简介2、安装
查看>>
php设计模式20-装饰着模式
查看>>
查询服务器基本硬件配置信息
查看>>
约瑟夫·奈:透视网络空间
查看>>
【数据安全案例】中电信外包公司离职员工潜入电信网络偷走客户积分换礼品...
查看>>
C/C++位操作
查看>>
我的友情链接
查看>>
CPU 处理器架构知识
查看>>
我的友情链接
查看>>
精心专为Cubieboard打造的Linux系统Cubian
查看>>
我的友情链接
查看>>
【例4】拦截×××(《信息学奥赛一本通》)
查看>>
马哥笔记第十三天系统启动流程、grub、模块、bash函数
查看>>
在lamp架构上部署mysql
查看>>