深入探究一下Java中不同的線程間數(shù)據(jù)通信方式
1、多線程如何共享數(shù)據(jù)
多線程數(shù)據(jù)共享可以分為以下2種情況，線程實現(xiàn)代碼相同及線程實現(xiàn)代碼不同。
線程實現(xiàn)代碼相同
即runnable中的代碼一致，這樣可以直接在實現(xiàn)中定義成員變量直接共享
public class SharedSameRunnableDemo {
public static void main(String[] args) {
Runnable runnable = new MySameRunnable();
Thread thread1 = new Thread(runnable);
Thread thread2 = new Thread(runnable);
thread1.start();
thread2.start();
}
private static class MySameRunnable implements Runnable {
private int sharedData = 0;
@Override
public synchronized void run() {
for (int i = 0; i < 5; i++) {
sharedData++;
System.out.println("Thread: " + Thread.currentThread().getName() + ",
sharedData: " + sharedData);
}
}
}
}
在上面的示例中，我們定義了一個名為 MySameRunnable 的內部類它的共享變量是sharedData，它實現(xiàn)了Runnable 接口，并重寫了 run() 方法。在 run() 方法中，我們使用了 synchronized 關鍵字來保證線程安全。然后在main() 方法中，我們創(chuàng)建了一個 MySameRunnable 實例 runnable，并將其傳入兩個不同的線程對象中。最后啟動這兩個線程。由于這兩個線程共享同一個 MySameRunnable 實例，因此它們執(zhí)行的代碼是相同的，并且可以訪問和修改sharedData 變量。通過這種方式，就可以實現(xiàn)多個線程共享數(shù)據(jù)，并確保線程安全。
線程實現(xiàn)代碼不相同
即runnable中的代碼不一致，MyRunnable1 MyRunnable2，利用一個對象SharedData，把runnable中的方法封裝到這個對象中去，數(shù)據(jù)也在這個對象中。如果多個線程實現(xiàn)的代碼不同，并且需要共享變量，可以使用一個單獨的類來存儲這些共享變量，并將它傳遞給所有的 Runnable 實例。以下是一個簡單的示例代碼：
public class SharedDifferentRauuableDemo {
public static void main(String[] args) {
SharedData sharedData = new SharedData();
Thread thread1 = new Thread(new MyRunnable1(sharedData));
Thread thread2 = new Thread(new MyRunnable2(sharedData));
thread1.start();
thread2.start();
}
private static class SharedData {
private int data = 0;
public synchronized void increment() {
data++;
System.out.println("IncrementThread: " + data);
}
public synchronized void decrement() {
data--;
System.out.println("DecrementThread: " + data);
}
}
private static class MyRunnable1 implements Runnable {
private SharedData sharedData;
public MyRunnable1(SharedData sharedData) {
this.sharedData = sharedData;
}
@Override
public void run() {
for (int i = 0; i < 5; i++) {
sharedData.increment();
try {
Thread.sleep(100);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
}
private static class MyRunnable2 implements Runnable {
private SharedData sharedData;
public MyRunnable2(SharedData sharedData) {
this.sharedData = sharedData;
}
@Override
public void run() {
for (int i = 0; i < 5; i++) {
sharedData.decrement();
try {
Thread.sleep(100);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
}
}
在上面的示例中，我們定義了一個 SharedData 類來存儲共享變量 data。這個類包含兩個同步方法 increment() 和 decrement()，用于增加和減少 data 的值，并輸出當前的值。然后我們創(chuàng)建了兩個 MyRunnable1 和 MyRunnable2 實例，它們分別傳遞了相同的 SharedData 對象。在 run() 方法中，它們調用 SharedData 對象的 increment() 和 decrement() 方法來進行數(shù)據(jù)修改，并使用 Thread.sleep() 方法讓線程休眠一段時間。
通過這種方式，就可以實現(xiàn)多個線程共享數(shù)據(jù)，并確保線程安全。
2、子線程如何繼承父線程數(shù)據(jù)
通過 InteritableThreadLocal實現(xiàn)共享
public class InheritableThreadLocalDemo {
private static final InheritableThreadLocal<String> inheritableThreadLocal
= new InheritableThreadLocal<>();
public static void main(String[] args) {
inheritableThreadLocal.set("Hello, World!");
Thread parentThread = new Thread(() -> {
System.out.println("Parent Thread: " + inheritableThreadLocal.get());
inheritableThreadLocal.set("Hello from Parent Thread!");
Thread childThread = new Thread(() -> {
System.out.println("Child Thread: " + inheritableThreadLocal.get());
});
childThread.start();
try {
childThread.join();
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println("Parent Thread: " + inheritableThreadLocal.get());
});
parentThread.start();
try {
parentThread.join();
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println("Main Thread: " + inheritableThreadLocal.get());
inheritableThreadLocal.remove();
}
}
在上面的示例中，我們創(chuàng)建了一個 InheritableThreadLocal 對象，并將其設置為“Hello, World!”。然后，我們創(chuàng)建了一個名為“parentThread”的線程，并在其中輸出 inheritableThreadLocal 的值。接下來，我們在父線程中將 inheritableThreadLocal 的值設置為“Hello from Parent Thread!”，并創(chuàng)建了一個名為“childThread”的線程，在其中輸出 inheritableThreadLocal 的值。
注意：由于 InheritableThreadLocal 是可繼承的，所以在子線程中也能夠獲取到父線程中設置的值。因此，當我們在子線程中輸出 inheritableThreadLocal 的值時，我們將看到輸出“Hello from Parent Thread!”。
最后，我們分別在父線程、子線程和主線程中輸出 inheritableThreadLocal 的值。由于我們在每個線程中都設置了 inheritableThreadLocal 的值，所以每個線程都將輸出不同的值。
請注意，在程序的結尾處，我們調用了 inheritableThreadLocal.remove() 方法來清除 InheritableThreadLocal 對象的值，并釋放相關的資源。這是一種良好的習慣，可以避免內存泄漏和數(shù)據(jù)污染等問題。
3、相關問題
1.請簡述Java中的多線程通信機制，并解釋一下為什么需要多線程通信？
答：Java中的多線程通信機制是通過使用管道和共享變量來實現(xiàn)的。管道可以用來實現(xiàn)多個線程之間的數(shù)據(jù)傳遞和同步，共享變量可以用來實現(xiàn)多個線程之間的數(shù)據(jù)共享和同步。
2.Java 中，在多個線程之間共享數(shù)據(jù)的方式主要有以下幾種：
1）共享變量：可以將需要共享的變量定義為靜態(tài)變量或公共變量，然后通過同步控制機制（例如 synchronized 關鍵字、Lock 接口等）保證多線程訪問這些變量時的安全性。
2）ThreadLocal：通過 ThreadLocal 類可以在每個線程中創(chuàng)建獨立的變量副本，從而避免了對共享變量的競爭。
3）Callable 和 Future 接口：在子線程執(zhí)行任務后，可以通過 Callable 和 Future 接口返回結果給主線程。主線程可以通過 Future.get() 方法獲取子線程的執(zhí)行結果，從而完成數(shù)據(jù)共享。
4）BlockingQueue：可以使用 BlockingQueue 來實現(xiàn)數(shù)據(jù)共享和通信，生產者線程向 BlockingQueue 中添加數(shù)據(jù)，消費者線程從隊列中獲取數(shù)據(jù)。
5）CyclicBarrier 和 CountDownLatch：可以使用 CyclicBarrier 和 CountDownLatch 等同步工具來協(xié)調多個線程之間的操作，從而實現(xiàn)數(shù)據(jù)共享。
到此這篇關于深入探究一下Java中不同的線程間數(shù)據(jù)通信方式的文章就介紹到這了,更多相關Java線程數(shù)據(jù)通信方式內容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關文章希望大家以后多多支持腳本之家！
相關文章
Java Socket+多線程實現(xiàn)多人聊天室功能
這篇文章主要為大家詳細介紹了Java Socket+多線程實現(xiàn)多人聊天室功能，文中示例代碼介紹的非常詳細，具有一定的參考價值，感興趣的小伙伴們可以參考一下2021-07-07
Java并發(fā)編程示例(六)：等待線程執(zhí)行終止
這篇文章主要介紹了Java并發(fā)編程示例(六)：等待線程執(zhí)行終止,在本節(jié),示例程序演示等待初始化方法完成后,再去執(zhí)行其他任務,需要的朋友可以參考下2014-12-12
SpringBoot使用MyBatis-Plus解決Invalid?bound?statement異常
這篇文章主要介紹了SpringBoot使用MyBatis-Plus解決Invalid?bound?statement異常，文章圍繞主題展開詳細的內容介紹，具有一定的參考價值，需要的小伙伴可以參考一下2022-09-09
在工作中或者學習過程中,有一些特殊情況我們需要來切換java版本來做比較,比如一些新特性等等的相關資料,這篇文章主要介紹了多個版本JAVA切換的相關資料,文中通過圖文介紹的非常詳細,需要的朋友可以參考下2024-09-09
java.net.ConnectException: Connection refused問題解決辦法
這篇文章主要介紹了java.net.ConnectException: Connection refused問題解決辦法的相關資料,需要的朋友可以參考下2016-12-12
Spring Boot 2.0多數(shù)據(jù)源配置方法實例詳解
這篇文章主要介紹了Spring Boot 2.0多數(shù)據(jù)源配置方法實例詳解,非常不錯，具有一定的參考借鑒價值，需要的朋友可以參考下2018-09-09
MyBatis中,select 標簽是最常用也是功能最強大的 SQL 語言,用于執(zhí)行查詢操作,本文就來介紹了MyBatis select標簽的使用示例,具有一定的參考價值,感興趣的可以了解一下2023-10-10
這篇文章主要為大家詳細介紹了JavaWeb登陸功能實現(xiàn)代碼，文中示例代碼介紹的非常詳細，具有一定的參考價值，感興趣的小伙伴們可以參考一下2016-10-10
java操作json對象出現(xiàn)StackOverflow錯誤的問題及解決
這篇文章主要介紹了java操作json對象出現(xiàn)StackOverflow錯誤的問題及解決方案，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教2022-06-06
SpringBoot開啟server:compression:enabled(Illegal characte
本文主要介紹了SpringBoot開啟server:compression:enabled(Illegal character ((CTRL-CHAR, code 31)))的的問題解決,具有一定的參考價值,感興趣的可以了解一下2025-03-03