徹底搞懂Java多線(xiàn)程(四)
SimpleDateFormat非線(xiàn)程安全問(wèn)題
實(shí)現(xiàn)1000個(gè)線(xiàn)程的時(shí)間格式化
package SimpleDateFormat;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.concurrent.LinkedBlockingDeque;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;
/**
* user：ypc；
* date：2021-06-13;
* time: 17:30;
*/
public class SimpleDateFormat1 {
private static SimpleDateFormat simpleDateFormat = new SimpleDateFormat("mm:ss");
public static void main(String[] args) {
ThreadPoolExecutor threadPoolExecutor = new ThreadPoolExecutor(10,10,100,
TimeUnit.MILLISECONDS,new LinkedBlockingDeque<>(1000),new ThreadPoolExecutor.DiscardPolicy());
for (int i = 0; i < 1001; i++) {
int finalI = i;
threadPoolExecutor.submit(new Runnable() {
@Override
public void run() {
Date date = new Date(finalI * 1000);
myFormatTime(date);
}
});
}
threadPoolExecutor.shutdown();
}
private static void myFormatTime(Date date){
System.out.println(simpleDateFormat.format(date));
}
}
產(chǎn)生了線(xiàn)程不安全的問(wèn)題👇：
這是因?yàn)椋?/p>
多線(xiàn)程的情況下：
線(xiàn)程1在時(shí)間片用完之后，線(xiàn)程2來(lái)setTime()那么線(xiàn)程1的得到了線(xiàn)程2的時(shí)間。
所以可以使用加鎖的操作：
就不會(huì)有重復(fù)的時(shí)間了
但是雖然可以解決線(xiàn)程不安全的問(wèn)題，但是排隊(duì)等待鎖，性能就會(huì)變得低
所以可以使用局部變量：
也解決了線(xiàn)程不安全的問(wèn)題：
但是每次也都會(huì)創(chuàng)建新的私有變量
那么有沒(méi)有一種方案既可以避免加鎖排隊(duì)執(zhí)行，又不會(huì)每次創(chuàng)建任務(wù)的時(shí)候不會(huì)創(chuàng)建私有的變量呢？
那就是ThreadLocal👇：
ThreadLocal
ThreadLocal的作用就是讓每一個(gè)線(xiàn)程都擁有自己的變量。
那么選擇鎖還是ThreadLocal?
看創(chuàng)建實(shí)列對(duì)象的復(fù)用率，如果復(fù)用率比較高的話(huà)，就使用ThreadLocal。
ThreadLocal的原理
類(lèi)ThreadLocal的主要作用就是將數(shù)據(jù)放到當(dāng)前對(duì)象的Map中，這個(gè)Map時(shí)thread類(lèi)的實(shí)列變量。類(lèi)ThreadLocal自己不管理、不存儲(chǔ)任何的數(shù)據(jù)，它只是數(shù)據(jù)和Map之間的橋梁。
執(zhí)行的流程：數(shù)據(jù)—>ThreadLocal—>currentThread()—>Map。
執(zhí)行后每個(gè)Map存有自己的數(shù)據(jù)，Map中的key中存儲(chǔ)的就是ThreadLocal對(duì)象，value就是存儲(chǔ)的值。每個(gè)Thread的Map值只對(duì)當(dāng)前的線(xiàn)程可見(jiàn)，其它的線(xiàn)程不可以訪(fǎng)問(wèn)當(dāng)前線(xiàn)程對(duì)象中Map的值。當(dāng)前的線(xiàn)程被銷(xiāo)毀，Map也隨之被銷(xiāo)毀，Map中的數(shù)據(jù)如果沒(méi)有被引用、沒(méi)有被使用，則隨時(shí)GC回收。
ThreadLocal常用方法
set(T)：將內(nèi)容存儲(chǔ)到ThreadLocal
get():從線(xiàn)程去私有的變量
remove():從線(xiàn)程中移除私有變量
package ThreadLocalDemo;
import java.text.SimpleDateFormat;
/**
* user：ypc；
* date：2021-06-13;
* time: 18:37;
*/
public class ThreadLocalDemo1 {
private static ThreadLocal<SimpleDateFormat> threadLocal = new ThreadLocal<>();
public static void main(String[] args) {
//設(shè)置私有變量
threadLocal.set(new SimpleDateFormat("mm:ss"));
//得到ThreadLocal
SimpleDateFormat simpleDateFormat = threadLocal.get();
//移除
threadLocal.remove();
}
}
ThreadLocal的初始化
ThreadLocal提供了兩種初始化的方法
initialValue()和
initialValue()初始化：
package ThreadLocalDemo;
import java.text.SimpleDateFormat;
import java.util.Date;
/**
* user：ypc；
* date：2021-06-13;
* time: 19:07;
*/
public class ThreadLocalDemo2 {
//創(chuàng)建并初始化ThreadLocal
private static ThreadLocal<SimpleDateFormat> threadLocal = new ThreadLocal() {
@Override
protected SimpleDateFormat initialValue() {
System.out.println(Thread.currentThread().getName() + "執(zhí)行了自己的threadLocal中的初始化方法initialValue()");
return new SimpleDateFormat("mm:ss");
}
};
public static void main(String[] args) {
Thread thread1 = new Thread(() -> {
Date date = new Date(5000);
System.out.println("thread0格式化時(shí)間之后得結(jié)果時(shí)：" + threadLocal.get().format(date));
});
thread1.setName("thread0");
thread1.start();
Thread thread2 = new Thread(() -> {
Date date = new Date(6000);
System.out.println("thread1格式化時(shí)間之后得結(jié)果時(shí)：" + threadLocal.get().format(date));
});
thread2.setName("thread1");
thread2.start();
}
}
withInitial方法初始化：
package ThreadLocalDemo;
import java.util.function.Supplier;
/**
* user：ypc；
* date：2021-06-14;
* time: 17:23;
*/
public class ThreadLocalDemo3 {
private static ThreadLocal<String> stringThreadLocal =
ThreadLocal.withInitial(new Supplier<String>() {
@Override
public String get() {
System.out.println("執(zhí)行了withInitial（）方法");
return "我是" + Thread.currentThread().getName() + "的ThreadLocal";
}
});
public static void main(String[] args) {
Thread thread1 = new Thread(() -> {
System.out.println(stringThreadLocal.get());
});
thread1.start();
Thread thread2 = new Thread(new Runnable() {
@Override
public void run() {
System.out.println(stringThreadLocal.get());
}
});
thread2.start();
}
}
注意：
ThreadLocal如果使用了set()方法的話(huà)，那么它的初始化方法就不會(huì)起作用了。
來(lái)看：👇
package ThreadLocalDemo;
/**
* user：ypc；
* date：2021-06-14;
* time: 18:43;
*/
class Tools {
public static ThreadLocal t1 = new ThreadLocal();
}
class ThreadA extends Thread {
@Override
public void run() {
for (int i = 0; i < 10; i++) {
System.out.println("在ThreadA中取值：" + Tools.t1.get());
try {
Thread.sleep(100);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
}
public class ThreadLocalDemo4 {
public static void main(String[] args) throws InterruptedException {
//main是ThreadA 的 父線(xiàn)程 讓main線(xiàn)程set，ThreadA，是get不到的
if (Tools.t1.get() == null) {
Tools.t1.set("main父線(xiàn)程的set");
}
System.out.println("main get 到了: " + Tools.t1.get());
Thread.sleep(1000);
ThreadA a = new ThreadA();
a.start();
}
}
類(lèi)ThreadLocal不能實(shí)現(xiàn)值的繼承，那么就可以使用InheritableThreadLocal了👇
InheritableThreadLocal的使用
使用InheritableThreadLocal可以使子線(xiàn)程繼承父線(xiàn)程的值
在來(lái)看運(yùn)行的結(jié)果：
子線(xiàn)程有最新的值，父線(xiàn)程依舊是舊的值
package ThreadLocalDemo;
/**
* user：ypc；
* date：2021-06-14;
* time: 19:07;
*/
class ThreadB extends Thread{
@Override
public void run() {
for (int i = 0; i < 10; i++) {
System.out.println("在ThreadB中取值：" + Tools.t1.get());
if (i == 5){
Tools.t1.set("我是ThreadB中新set()");
}
try {
Thread.sleep(100);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
}
public class ThreadLocalDemo5 {
public static void main(String[] args) throws InterruptedException {
if (Tools.t1.get() == null) {
Tools.t1.set("main父線(xiàn)程的set");
}
System.out.println("main get 到了: " + Tools.t1.get());
Thread.sleep(1000);
ThreadA a = new ThreadA();
a.start();
Thread.sleep(5000);
for (int i = 0; i < 10; i++) {
System.out.println("main的get是：" + Tools.t1.get());
Thread.sleep(100);
}
}
}
ThreadLocal的臟讀問(wèn)題來(lái)看👇
package ThreadLocalDemo;
import java.util.concurrent.LinkedBlockingDeque;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;
/**
* user：ypc；
* date：2021-06-14;
* time: 19:49;
*/
public class ThreadLocalDemo6 {
private static ThreadLocal<String> threadLocal = new ThreadLocal<>();
private static class MyThread extends Thread {
private static boolean flag = false;
@Override
public void run() {
String name = this.getName();
if (!flag) {
threadLocal.set(name);
System.out.println(name + "設(shè)置了" + name);
flag = true;
}
System.out.println(name + "得到了" + threadLocal.get());
}
}
public static void main(String[] args) {
ThreadPoolExecutor threadPoolExecutor = new ThreadPoolExecutor(1, 1, 0,
TimeUnit.MILLISECONDS, new LinkedBlockingDeque<>(10));
for (int i = 0; i < 2; i++) {
threadPoolExecutor.execute(new MyThread());
}
threadPoolExecutor.shutdown();
}
}
發(fā)生了臟讀：
線(xiàn)程池復(fù)用了線(xiàn)程，也復(fù)用了這個(gè)線(xiàn)程相關(guān)的靜態(tài)屬性，就導(dǎo)致了臟讀
那么如何避免臟讀呢？
去掉static 之后：
總結(jié)
本篇文章就到這里了，希望對(duì)你有些幫助，也希望你可以多多關(guān)注腳本之家的更多內(nèi)容！
相關(guān)文章
這篇文章主要介紹了Intellij IDEA官方最完美編程字體Mono使用，文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧2020-03-03
Java如何實(shí)現(xiàn)自定義異常類(lèi)
這篇文章主要介紹了Java如何實(shí)現(xiàn)自定義異常類(lèi),文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下2020-02-02
這篇文章主要介紹了JMeter導(dǎo)入自定義的Jar包的詳解教程,本文通過(guò)圖文并茂的形式給大家介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值，需要的朋友可以參考下2020-07-07
這篇文章主要介紹了Linux如何尋找Java安裝路徑問(wèn)題,具有很好的參考價(jià)值,希望對(duì)大家有所幫助,如有錯(cuò)誤或未考慮完全的地方,望不吝賜教2024-03-03
本文將基于Spring Boot介紹兩種生成二維碼的實(shí)現(xiàn)方式，一種是基于Google開(kāi)發(fā)工具包，另一種是基于Hutool來(lái)實(shí)現(xiàn)，下面我們將基于Spring Boot，并采用兩種方式實(shí)現(xiàn)二維碼的生成，對(duì)于每一種方式還提供兩種類(lèi)型的二維碼返回形式,需要的朋友可以參考下2023-09-09
Alibaba?Nacos配置中心動(dòng)態(tài)感知原理示例解析
這篇文章主要介紹了Alibaba?Nacos配置中心動(dòng)態(tài)感知原理示例解析，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進(jìn)步，早日升職加薪2023-08-08
Java主線(xiàn)程捕獲子線(xiàn)程異常的實(shí)現(xiàn)
本文主要介紹了Java主線(xiàn)程捕獲子線(xiàn)程異常的實(shí)現(xiàn),文中通過(guò)示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧2024-04-04
SpringBoot實(shí)現(xiàn)連接nacos并支持多環(huán)境部署
這篇文章主要介紹了SpringBoot實(shí)現(xiàn)連接nacos并支持多環(huán)境部署方式,具有很好的參考價(jià)值,希望對(duì)大家有所幫助,如有錯(cuò)誤或未考慮完全的地方,望不吝賜教2024-06-06
SpringMVC中RequestBody注解的List參數(shù)傳遞方式
這篇文章主要介紹了SpringMVC中RequestBody注解的List參數(shù)傳遞方式，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方，望不吝賜教2022-10-10
SpringBoot業(yè)務(wù)邏輯異常的處理方法介紹
本篇文章為大家展示了如何在SpringBoot中統(tǒng)一處理邏輯異常，內(nèi)容簡(jiǎn)明扼要并且容易理解，絕對(duì)能使你眼前一亮，通過(guò)這篇文章的詳細(xì)介紹希望你能有所收獲2022-09-09