線程封閉

zero 發(fā)布于2019-08-16 17:16 / 1806人閱讀

摘要：盡量少使用全局變量變量不是常量線程封閉比較好的封閉方法維護(hù)的是一個(gè)這個(gè)是線程的名稱多為我們所有封閉的值作為。在線程執(zhí)行完之后將中的數(shù)據(jù)清空防止內(nèi)存溢出。最后我們用測試發(fā)現(xiàn)打印了線程，中變量值只要是一個(gè)線程中不管在哪個(gè)類中都是共享的。

我們可以通過把對象設(shè)計(jì)成不可變對象來躲避并發(fā)，我們還可以通過使用線程封閉來實(shí)現(xiàn)線程安全，所謂線程封閉

就是將數(shù)據(jù)都封裝到一個(gè)線程里，不讓其他線程訪問。

Ad-hoc 線程封閉程序控制實(shí)現(xiàn)，比較脆弱，盡量少用

堆棧封閉：局部變量，無并發(fā)問題，在項(xiàng)目中使用最多，簡單說就是局部變量，方法的變量都拷貝到線程的堆棧中，只有這個(gè)線程能訪問到。盡量少使用全局變量（變量不是常量）

ThreadLocal線程封閉：比較好的封閉方法

ThreadLocal維護(hù)的是一個(gè)map 這個(gè)map是線程的名稱多為key 我們所有封閉的值作為value。
我們做使用Filter做登錄操作都做過，我們現(xiàn)在來使用ThreadLoad來存儲(chǔ)一下用戶信息。

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();
    }
}

聲明一個(gè)ThreadLoad對象用來存儲(chǔ)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的內(nèi)容，我們在filter中將線程id加入到ThreadLoad中，然后在controller中獲取，看看能不能獲取的到。在線程執(zhí)行完之后將ThreadLoad中的數(shù)據(jù)清空防止內(nèi)存溢出。

@Controller
@RequestMapping("/threadLocal")
public class ThreadLocalController {

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

最后我們用postman測試發(fā)現(xiàn)打印了線程id，ThreadLoad中變量值只要是一個(gè)線程中不管在哪個(gè)類中都是共享的。