Java并發(fā)編程示例(九)：本地線程變量的使用
共享數(shù)據(jù)是并發(fā)程序最關(guān)鍵的特性之一。對(duì)于無(wú)論是繼承Thread類的對(duì)象，還是實(shí)現(xiàn)Runnable接口的對(duì)象，這都是一個(gè)非常周重要的方面。
如果創(chuàng)建了一個(gè)實(shí)現(xiàn)Runnable接口的類的對(duì)象，并使用該對(duì)象啟動(dòng)了一系列的線程，則所有這些線程共享相同的屬性。換句話說(shuō)，如果一個(gè)線程修改了一個(gè)屬性，則其余所有線程都會(huì)受此改變的影響。
有時(shí)，我們更希望能在線程內(nèi)單獨(dú)使用，而不和其他使用同一對(duì)象啟動(dòng)的線程共享。Java并發(fā)接口提供了一種很清晰的機(jī)制來(lái)滿足此需求，該機(jī)制稱為本地線程變量。該機(jī)制的性能也非常可觀。
知其然
按照下面所示步驟，完成示例程序。
1.首先，實(shí)現(xiàn)一個(gè)有上述問(wèn)題的程序。創(chuàng)建一個(gè)名為UnsafeTask的類，并且實(shí)現(xiàn)Runnable接口。在類中聲明一個(gè)java.util.Date類型的私有屬性。代碼如下：
public class UnsafeTask implements Runnable {
private Date startDate;
2.實(shí)現(xiàn)UnsafeTask的run()方法，該方法實(shí)例化startDate屬性，并將其值輸出到控制臺(tái)上。休眠隨機(jī)一段時(shí)間，然后再次將startDate屬性的值輸出到控制臺(tái)上。代碼如下：
@Override
public void run() {
startDate = new Date();
System.out.printf("Starting Thread: %s : %s\n",
Thread.currentThread().getId(), startDate);
try {
TimeUnit.SECONDS.sleep((int) Math.rint(Math.random() * 10));
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.printf("Thread Finished: %s : %s\n",
Thread.currentThread().getId(), startDate);
}
3.實(shí)現(xiàn)問(wèn)題程序的主類。創(chuàng)建一個(gè)帶有main()方法的類，UnsafeMain。在main()方法中，創(chuàng)建一個(gè)UnsafeTask對(duì)象，并使用該對(duì)象來(lái)創(chuàng)建10個(gè)Thread對(duì)象，來(lái)啟動(dòng)10個(gè)線程。在每個(gè)線程中間，休眠2秒鐘。代碼如下：
public class UnsafeMain {
public static void main(String[] args) {
UnsafeTask task = new UnsafeTask();
for (int i = 0; i < 10; i++) {
Thread thread = new Thread(task);
thread.start();
try {
TimeUnit.SECONDS.sleep(2);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
}
4.從上面的邏輯來(lái)看，每個(gè)線程都有一個(gè)不同的啟動(dòng)時(shí)間。但是，根據(jù)下面的輸出日志來(lái)看，出現(xiàn)了好多相同的時(shí)間值。如下：
Starting Thread: 9 : Sun Sep 29 23:31:08 CST 2013
Starting Thread: 10 : Sun Sep 29 23:31:10 CST 2013
Starting Thread: 11 : Sun Sep 29 23:31:12 CST 2013
Starting Thread: 12 : Sun Sep 29 23:31:14 CST 2013
Thread Finished: 9 : Sun Sep 29 23:31:14 CST 2013
Starting Thread: 13 : Sun Sep 29 23:31:16 CST 2013
Thread Finished: 10 : Sun Sep 29 23:31:16 CST 2013
Starting Thread: 14 : Sun Sep 29 23:31:18 CST 2013
Thread Finished: 11 : Sun Sep 29 23:31:18 CST 2013
Starting Thread: 15 : Sun Sep 29 23:31:20 CST 2013
Thread Finished: 12 : Sun Sep 29 23:31:20 CST 2013
Starting Thread: 16 : Sun Sep 29 23:31:22 CST 2013
Starting Thread: 17 : Sun Sep 29 23:31:24 CST 2013
Thread Finished: 17 : Sun Sep 29 23:31:24 CST 2013
Thread Finished: 15 : Sun Sep 29 23:31:24 CST 2013
Thread Finished: 13 : Sun Sep 29 23:31:24 CST 2013
Starting Thread: 18 : Sun Sep 29 23:31:26 CST 2013
Thread Finished: 14 : Sun Sep 29 23:31:26 CST 2013
Thread Finished: 18 : Sun Sep 29 23:31:26 CST 2013
Thread Finished: 16 : Sun Sep 29 23:31:26 CST 2013
5.如前文所示，我們準(zhǔn)備使用本地線程變量（the thread-local variables）機(jī)制來(lái)解決這個(gè)問(wèn)題。
6.創(chuàng)建一個(gè)名為SafeTask的類，并且實(shí)現(xiàn)Runnable接口。代碼如下：
public class SafeTask implements Runnable {
7.聲明一個(gè)ThreadLocal<Date>類型的對(duì)象，該對(duì)象實(shí)例化時(shí)，重寫(xiě)了initialValue()方法，在該方法中返回實(shí)際的日期值。代碼如下：
private static ThreadLocal<Date> startDate = new
ThreadLocal<Date>() {
@Override
protected Date initialValue() {
return new Date();
}
};
8.實(shí)現(xiàn)SafeTask類的run()方法。該方法和UnsafeTask的run()方法一樣，只是startDate屬性的方法方式稍微調(diào)整一下。代碼如下：
@Override
public void run() {
System.out.printf("Starting Thread: %s : %s\n",
Thread.currentThread().getId(), startDate.get());
try {
TimeUnit.SECONDS.sleep((int) Math.rint(Math.random() * 10));
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.printf("Thread Finished: %s : %s\n",
Thread.currentThread().getId(), startDate.get());
}
9.該安全示例的主類和非安全程序的主類基本相同，只是需要將UnsafeTask修改為SafeTask即可。具體代碼如下：
public class SafeMain {
public static void main(String[] args) {
SafeTask task = new SafeTask();
for (int i = 0; i < 10; i++) {
Thread thread = new Thread(task);
thread.start();
try {
TimeUnit.SECONDS.sleep(2);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
}
10.運(yùn)行程序，分析兩次輸入的不同之處。
為了規(guī)范類的命名，本文中主類的命名和原文稍有不同。另外，原文程序和文字?jǐn)⑹霾灰恢?。?yīng)該是一個(gè)筆誤。
知其所以然
下面是安全示例的執(zhí)行結(jié)果。從結(jié)果中，可以很容易地看出，每個(gè)線程都有一個(gè)屬于各自線程的startDate屬性值。程序輸入如下：
Starting Thread: 9 : Sun Sep 29 23:52:17 CST 2013
Starting Thread: 10 : Sun Sep 29 23:52:19 CST 2013
Starting Thread: 11 : Sun Sep 29 23:52:21 CST 2013
Thread Finished: 10 : Sun Sep 29 23:52:19 CST 2013
Starting Thread: 12 : Sun Sep 29 23:52:23 CST 2013
Thread Finished: 11 : Sun Sep 29 23:52:21 CST 2013
Starting Thread: 13 : Sun Sep 29 23:52:25 CST 2013
Thread Finished: 9 : Sun Sep 29 23:52:17 CST 2013
Starting Thread: 14 : Sun Sep 29 23:52:27 CST 2013
Starting Thread: 15 : Sun Sep 29 23:52:29 CST 2013
Thread Finished: 13 : Sun Sep 29 23:52:25 CST 2013
Starting Thread: 16 : Sun Sep 29 23:52:31 CST 2013
Thread Finished: 14 : Sun Sep 29 23:52:27 CST 2013
Starting Thread: 17 : Sun Sep 29 23:52:33 CST 2013
Thread Finished: 12 : Sun Sep 29 23:52:23 CST 2013
Thread Finished: 16 : Sun Sep 29 23:52:31 CST 2013
Thread Finished: 15 : Sun Sep 29 23:52:29 CST 2013
Starting Thread: 18 : Sun Sep 29 23:52:35 CST 2013
Thread Finished: 17 : Sun Sep 29 23:52:33 CST 2013
Thread Finished: 18 : Sun Sep 29 23:52:35 CST 2013
線程本地變量為每個(gè)線程存儲(chǔ)了一個(gè)屬性的副本?？梢允褂肨hreadLocal的get()方法獲取變量的值，使用set()方法設(shè)置變量的值。如果第一次訪問(wèn)線程本地變量，并且該變量還沒(méi)有賦值，則調(diào)用initialValue()方法為每個(gè)線程初始化一個(gè)值。
永無(wú)止境
ThreadLocal類還提供了remove()方法，來(lái)刪掉調(diào)用該方法的線程中存儲(chǔ)的本地變量值。
另外，Java并發(fā)API還提供了InheritableThreadLocal類，讓子線程可以接收所有可繼承的線程局部變量的初始值，以獲得父線程所具有的值。如果線程A有一個(gè)線程本地變量，當(dāng)線程A創(chuàng)建線程B時(shí)，則線程B將擁有和線程A一樣的線程本地變量。還可以重寫(xiě)childValue()，來(lái)初始化子線程的線程本地變量。該方法將接受從父線程以參數(shù)形式傳遞過(guò)來(lái)的線程本地變量的值。
拿來(lái)主義
本文是從 《Java 7 Concurrency Cookbook》 （D瓜哥竊譯為 《Java7并發(fā)示例集》 ）翻譯而來(lái)，僅作為學(xué)習(xí)資料使用。沒(méi)有授權(quán)，不得用于任何商業(yè)行為。
小有所成
下面是本節(jié)示例所包含的所有代碼的完整版。
UnsafeTask類的完整代碼：
package com.diguage.books.concurrencycookbook.chapter1.recipe9;
import java.util.Date;
import java.util.concurrent.TimeUnit;
/**
* 不能保證線程安全的例子
* Date: 2013-09-23
* Time: 23:58
*/
public class UnsafeTask implements Runnable {
private Date startDate;
@Override
public void run() {
startDate = new Date();
System.out.printf("Starting Thread: %s : %s\n",
Thread.currentThread().getId(), startDate);
try {
TimeUnit.SECONDS.sleep((int) Math.rint(Math.random() * 10));
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.printf("Thread Finished: %s : %s\n",
Thread.currentThread().getId(), startDate);
}
}
UnsafeMain類的完整代碼：
package com.diguage.books.concurrencycookbook.chapter1.recipe9;
import java.util.concurrent.TimeUnit;
/**
* 不安全的線程示例
* Date: 2013-09-24
* Time: 00:04
*/
public class UnsafeMain {
public static void main(String[] args) {
UnsafeTask task = new UnsafeTask();
for (int i = 0; i < 10; i++) {
Thread thread = new Thread(task);
thread.start();
try {
TimeUnit.SECONDS.sleep(2);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
}
SafeTask類的完整代碼：
package com.diguage.books.concurrencycookbook.chapter1.recipe9;
import java.util.Date;
import java.util.concurrent.TimeUnit;
/**
* 使用線程本地變量保證線程安全
* Date: 2013-09-29
* Time: 23:34
*/
public class SafeTask implements Runnable {
private static ThreadLocal<Date> startDate = new
ThreadLocal<Date>() {
@Override
protected Date initialValue() {
return new Date();
}
};
@Override
public void run() {
System.out.printf("Starting Thread: %s : %s\n",
Thread.currentThread().getId(), startDate.get());
try {
TimeUnit.SECONDS.sleep((int) Math.rint(Math.random() * 10));
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.printf("Thread Finished: %s : %s\n",
Thread.currentThread().getId(), startDate.get());
}
}
SafeMain類的完整代碼：
package com.diguage.books.concurrencycookbook.chapter1.recipe9;
import java.util.concurrent.TimeUnit;
/**
* 安全的線程示例
* Date: 2013-09-24
* Time: 00:04
*/
public class SafeMain {
public static void main(String[] args) {
SafeTask task = new SafeTask();
for (int i = 0; i < 10; i++) {
Thread thread = new Thread(task);
thread.start();
try {
TimeUnit.SECONDS.sleep(2);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
}
相關(guān)文章
如何使用Java實(shí)現(xiàn)請(qǐng)求deepseek
這篇文章主要為大家詳細(xì)介紹了如何使用Java實(shí)現(xiàn)請(qǐng)求deepseek功能,文中的示例代碼講解詳細(xì),感興趣的小伙伴可以跟隨小編一起學(xué)習(xí)一下2025-02-02
IntelliJ IDEA 創(chuàng)建 Java 項(xiàng)目及創(chuàng)建 Java 文件并運(yùn)行的詳細(xì)步驟
這篇文章主要介紹了IntelliJ IDEA 創(chuàng)建 Java 項(xiàng)目及創(chuàng)建 Java 文件并運(yùn)行的詳細(xì)步驟,本文通過(guò)圖文并茂的形式給大家介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值，需要的朋友可以參考下2020-11-11
springboot項(xiàng)目打包發(fā)布部署的過(guò)程及jar和war的區(qū)別
Spring Boot使用了內(nèi)嵌容器，因此它的部署方式也變得非常簡(jiǎn)單靈活，可以將Spring Boot項(xiàng)目打包成JAR包來(lái)獨(dú)立運(yùn)行，Spring Boot項(xiàng)目既可以生成WAR包發(fā)布，也可以生成JAR包發(fā)布，那么它們有什么區(qū)別呢2022-11-11
java并發(fā)編程之深入理解Synchronized的使用
文詳細(xì)講述了線程、進(jìn)程的關(guān)系及在操作系統(tǒng)中的表現(xiàn)，這是多線程學(xué)習(xí)必須了解的基礎(chǔ)。本文將接著講一下Java線程同步中的一個(gè)重要的概念synchronized，希望能夠給你有所幫助2021-06-06
這篇文章主要介紹了Java高階語(yǔ)法Volatile，文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧2019-03-03
springBoot項(xiàng)目中的static和templates文件夾的使用
本文主要介紹了springBoot項(xiàng)目中的static和templates文件夾的使用,文中通過(guò)示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧2024-07-07
在 Java 編程中,Stream 流提供了一種高效、便捷的方式來(lái)處理集合數(shù)據(jù),本文將詳細(xì)介紹 Java 中 Stream 流的用法,包括基礎(chǔ)用法、中級(jí)用法、高級(jí)用法以及一些特殊方法的使用,感興趣的朋友一起看看吧2024-12-12
這篇文章主要介紹了Linux安裝和卸載JDK8,第一種是使用yum命令一鍵安裝，默認(rèn)安裝目錄在/usr/lib/jvm第二種是手動(dòng)安裝，本文給大家介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值，需要的朋友可以參考下2022-09-09
MyBatis 中使用 Mapper 簡(jiǎn)化代碼的方法
這篇文章主要介紹了MyBatis 中使用 Mapper 簡(jiǎn)化代碼的方法,本文給大家介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值，需要的朋友可以參考下2021-01-01
Java多線程 Guarded Suspension設(shè)計(jì)模式
這篇文章主要介紹了Java多線程 Guarded Suspension設(shè)計(jì)模式,Guarded Suspension意為保護(hù)暫停，其核心思想是僅當(dāng)服務(wù)進(jìn)程準(zhǔn)備好時(shí)，才提供服務(wù),文章圍繞Java多線程 Guarded Suspension展開(kāi)內(nèi)容,需要的朋友可以參考一下2021-10-10