JAvaにおけるThreadLocalの正しい使い方
5501 ワード
JAvaにおけるThreadLocalの正しい使い方
使用法1:関連データクラスでprivate static ThreadLocalThreaLocalを作成するJDKドキュメントで説明:ThreadLocal instances are typically private static fields in classes that wish to associate state with a thread.ユーザID、トランザクションIDなどのクラスを介してスレッドにステータスを関連付ける場合、private staticタイプのThreadLocalインスタンスは、通常、このクラスで定義されます.
たとえば、次のクラスでは、プライベート静的ThreadLocalインスタンス(serialNum)は、クラスを呼び出す静的SerialNum.get()メソッドの各スレッドについて、現在のスレッドのシーケンス番号を返す「シーケンス番号」を維持します.(スレッドのシリアル番号は、SerialNum.get()が最初に呼び出されたときに割り当てられ、後続の呼び出しでは変更されません.)
【例】
使用法2:UtilクラスでThreadLocalを作成する
これは、ThreadLocalの作成をツールクラスに配置する上での拡張です.
【例】hibernateなどのツールクラス:
使用法3:RunnableでThreadLocalを作成する
もう1つの方法は、スレッドクラス内でThreadLocalを作成することです.基本的な手順は次のとおりです.
1.マルチスレッドのクラス(ThreadDemoクラスなど)に、スレッド間で分離処理が必要なオブジェクトxxxを保存するためのThreadLocalオブジェクトthreadXxxを作成します.
2.ThreadDemoクラスで、アクセスを分離するデータを取得するメソッドgetXxx()を作成し、メソッドでThreadLocalオブジェクトがnullの場合、new()アクセスタイプを分離するオブジェクトを作成し、適用するタイプに強制的に変換する.
3、ThreadDemoクラスのrun()メソッドでは、getXxx()メソッドを呼び出して操作するデータを取得することで、スレッドごとに1つのデータオブジェクトに対応し、いつでもこのオブジェクトが操作されることを保証することができます.
読書に感謝して、みんなを助けることができることを望んで、みんなの当駅に対する支持に感謝します!
使用法1:関連データクラスでprivate static ThreadLocalThreaLocalを作成するJDKドキュメントで説明:ThreadLocal instances are typically private static fields in classes that wish to associate state with a thread.ユーザID、トランザクションIDなどのクラスを介してスレッドにステータスを関連付ける場合、private staticタイプのThreadLocalインスタンスは、通常、このクラスで定義されます.
たとえば、次のクラスでは、プライベート静的ThreadLocalインスタンス(serialNum)は、クラスを呼び出す静的SerialNum.get()メソッドの各スレッドについて、現在のスレッドのシーケンス番号を返す「シーケンス番号」を維持します.(スレッドのシリアル番号は、SerialNum.get()が最初に呼び出されたときに割り当てられ、後続の呼び出しでは変更されません.)
public class SerialNum {
// The next serial number to be assigned
private static int nextSerialNum = 0;
private static ThreadLocal serialNum = new ThreadLocal() {
protected synchronized Object initialValue() {
return new Integer(nextSerialNum++);
}
};
public static int get() {
return ((Integer) (serialNum.get())).intValue();
}
}
【例】
public class ThreadContext {
private String userId;
private Long transactionId;
private static ThreadLocal threadLocal = new ThreadLocal(){
@Override
protected ThreadContext initialValue() {
return new ThreadContext();
}
};
public static ThreadContext get() {
return threadLocal.get();
}
public String getUserId() {
return userId;
}
public void setUserId(String userId) {
this.userId = userId;
}
public Long getTransactionId() {
return transactionId;
}
public void setTransactionId(Long transactionId) {
this.transactionId = transactionId;
}
}
使用法2:UtilクラスでThreadLocalを作成する
これは、ThreadLocalの作成をツールクラスに配置する上での拡張です.
【例】hibernateなどのツールクラス:
public class HibernateUtil {
private static Log log = LogFactory.getLog(HibernateUtil.class);
private static final SessionFactory sessionFactory; // SessionFactory
static {
try {
// hibernate.cfg.xml SessionFactory
sessionFactory = new Configuration().configure().buildSessionFactory();
} catch (Throwable ex) {
log.error(" SessionFactory !", ex);
throw new ExceptionInInitializerError(ex);
}
}
// session, Hibernate Session
public static final ThreadLocal session = new ThreadLocal();
/**
* Session
* @return Session
* @throws HibernateException
*/
public static Session currentSession() throws HibernateException {
Session s = (Session) session.get();
// Session , Session
if (s == null) {
s = sessionFactory.openSession();
session.set(s); // Session
}
return s;
}
public static void closeSession() throws HibernateException {
// , Session
Session s = (Session) session.get();
session.set(null);
if (s != null)
s.close();
}
}
使用法3:RunnableでThreadLocalを作成する
もう1つの方法は、スレッドクラス内でThreadLocalを作成することです.基本的な手順は次のとおりです.
1.マルチスレッドのクラス(ThreadDemoクラスなど)に、スレッド間で分離処理が必要なオブジェクトxxxを保存するためのThreadLocalオブジェクトthreadXxxを作成します.
2.ThreadDemoクラスで、アクセスを分離するデータを取得するメソッドgetXxx()を作成し、メソッドでThreadLocalオブジェクトがnullの場合、new()アクセスタイプを分離するオブジェクトを作成し、適用するタイプに強制的に変換する.
3、ThreadDemoクラスのrun()メソッドでは、getXxx()メソッドを呼び出して操作するデータを取得することで、スレッドごとに1つのデータオブジェクトに対応し、いつでもこのオブジェクトが操作されることを保証することができます.
public class ThreadLocalTest implements Runnable{
ThreadLocal studenThreadLocal = new ThreadLocal();
@Override
public void run() {
String currentThreadName = Thread.currentThread().getName();
System.out.println(currentThreadName + " is running...");
Random random = new Random();
int age = random.nextInt(100);
System.out.println(currentThreadName + " is set age: " + age);
Studen studen = getStudent(); // , new student , student
studen.setAge(age);
System.out.println(currentThreadName + " is first get age: " + studen.getAge());
try {
Thread.sleep(500);
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println( currentThreadName + " is second get age: " + studen.getAge());
}
private Studen getStudent() {
Studen studen = studenThreadLocal.get();
if (null == studen) {
studen = new Studen();
studenThreadLocal.set(studen);
}
return studen;
}
public static void main(String[] args) {
ThreadLocalTest t = new ThreadLocalTest();
Thread t1 = new Thread(t,"Thread A");
Thread t2 = new Thread(t,"Thread B");
t1.start();
t2.start();
}
}
class Studen{
int age;
public int getAge() {
return age;
}
public void setAge(int age) {
this.age = age;
}
}
読書に感謝して、みんなを助けることができることを望んで、みんなの当駅に対する支持に感謝します!