歡迎光臨
每天分享高質量文章

ThreadLocal的使用場景

最近專案中遇到如下的場景:在執行資料遷移時,需要按照用戶粒度加鎖,因此考慮使用排他鎖,遷移工具和業務服務屬於兩個服務,因此需要使用分佈式鎖。

我們使用快取(Tair或者Redis)實現分佈式鎖,具體代碼如下:

  1. @Service

  2. public class Locker {

  3.    @Resource(name = "tairClientUtil")

  4.    private TairClientUtil tairClientUtil;

  5.    private ThreadLocal<Long> lockerBeanThreadLocal = new ThreadLocal<>();

  6.    public void init(long userid) {

  7.        lockerBeanThreadLocal.remove();

  8.        lockerBeanThreadLocal.set(userid);

  9.    }

  10.    public void updateLock() {

  11.        String lockKey = Constants.MIGRATION_PREFIX + lockerBeanThreadLocal.get();

  12.        tairClientUtil.incr(lockKey, Constants.COUNT_EXPIRE);

  13.    }

  14.    public void invalidLock() {

  15.        String lockKey = Constants.MIGRATION_PREFIX + lockerBeanThreadLocal.get();

  16.        tairClientUtil.invalid(lockKey);

  17.    }

  18. }

因為每個執行緒可能攜帶不同的userid發起請求,因此在這裡使用ThreadLocal變數存放userid,使得每個執行緒都有一份自己的副本。

參考官方文件:ThreadLocal的用法,這個類提供“thread-local”變數,這些變數與執行緒的區域性變數不同,每個執行緒都儲存一份改變數的副本,可以通過get或者set方法訪問。如果開發者希望將類的某個靜態變數(user ID或者transaction ID)與執行緒狀態關聯,則可以考慮使用ThreadLocal。

舉個例子,下麵的類為每個執行緒生成不同的ID,當某個執行緒第一次呼叫Thread.get()時,會為該執行緒賦予一個ID,並且在後續的呼叫中不再改變。

  1. import java.util.concurrent.atomic.AtomicInteger;

  2. public class ThreadId {

  3.     // Atomic integer containing the next thread ID to be assigned

  4.     private static final AtomicInteger nextId = new AtomicInteger(0);

  5.     // Thread local variable containing each thread's ID

  6.     private static final ThreadLocal<Integer> threadId =

  7.         new ThreadLocal<Integer>() {

  8.             @Override protected Integer initialValue() {

  9.                 return nextId.getAndIncrement();

  10.         }

  11.     };

  12.     // Returns the current thread's unique ID, assigning it if necessary

  13.     public static int get() {

  14.         return threadId.get();

  15.     }

  16. }

每個執行緒會“隱式”包含一份thread-local變數的副本,只要執行緒還處於活躍狀態,就可以訪問該變數;當執行緒停止後,如果沒有其他執行緒持有該thread-local變數,則該變數的副本會提交給垃圾回收器。

赞(0)

分享創造快樂

© 2021 知識星球   网站地图