上篇博客說到了多線程的創建方式,本篇博客說說自己對於多個線程間的共享變量的理解。
一、概述
首先,分析集中不同的變量共享場景:
1,多個線程執行同樣的代碼
在這種情況下,可以使用同一個Runnable對象(看上一篇博客,這是一種創建線程的方式)將需要共享的數據,植入這個Runnable對象里面。例如買票系統,余票是需要共享的,不過在這樣做的時候,我想還應該加上synchronized關鍵字修飾!
2,多個線程執行的代碼不一樣
在這種情況下,就兩種思路可以實現(這里參考張孝祥老師的觀點)
其一:將共享數據封裝再另外一個對象中,然后將這個對象逐一傳遞給各個Runnable對象。每個線程對共享數據的操作方法也分配到那個對象身上去完成,這樣容易實現對改數據進行的各個操作的互斥和通信。
其二:將這些Runnable對象作為某一個類中的內部類,共享數據作為這個外部類中的成員變量,每個線程對共享數據的操作方法也分配給外部類,以便實現對共享數據進行的各個操作的互斥和通信,作為內部類的各個Runnable對象調用外部類的這些方法。
組合:將共享數據封裝再另外一個對象中,每個線程對共享數據的操作方法也分配到那個對象身上去完成,對象作為這個外部類中的成員變量或方法中的局部變量,每個線程的Runnable對象作為外部類中的成員內部類或局部內部類。(示例代碼所使用的方法),總之,要同步互斥的幾段代碼最好是分別放在幾個獨立的方法中,這些方法再放在同一個類中,這樣比較好容易實現它們之間的同步互斥通信
3,簡單粗暴的方式
在程序中,定義一個static變量
二、代碼示例
<span style="font-family:KaiTi_GB2312;font-size:18px;">package Angel; public class MultiThreadShareData { private static ShareData1 data1 = new ShareData1(); public static void main(String[] args) { ShareData1 data2 = new ShareData1(); new Thread(new MyRunnable1(data2)).start();//減 new Thread(new MyRunnable2(data2)).start();//加 final ShareData1 data1 = new ShareData1(); new Thread(new Runnable(){ @Override public void run() { data1.decrement();//減 } }).start(); new Thread(new Runnable(){ @Override public void run() { data1.increment();//加 } }).start(); } } class MyRunnable1 implements Runnable{ private ShareData1 data1; public MyRunnable1(ShareData1 data1){ this.data1 = data1; } public void run() { data1.decrement(); } } class MyRunnable2 implements Runnable{ private ShareData1 data1; public MyRunnable2(ShareData1 data1){ this.data1 = data1; } public void run() { data1.increment(); } } class ShareData1{ private int j = 0; public synchronized void increment(){ j++; System.out.println(j); } public synchronized void decrement(){ j--; System.out.println(j); } }</span>
三、總結
實現共享數據,不只有這個方式,還應該有已經封裝好的更為方便的方式,下篇博客接着介紹。在說到這個基礎知識點的時候,突然想到了另外一個關於多線程的基本點,就是在使用多線程的時候,我們會常用到wait()和sleep()方法,那么這兩種方法到底有什么區別呢?先看一下線程的狀態圖:
簡單說來:sleep()方法是屬於Thread類中的。而wait()方法是屬於Object類中的。
sleep()方法導致了程序暫停執行指定的時間,讓出cpu該其他線程,但是他的監控狀態依然保持者,當指定的時間到了又會自動恢復運行狀態。在調用sleep()方法的過程中,線程不會釋放對象鎖。
當調用wait()方法的時候,線程會放棄對象鎖,進入等待此對象的等待鎖定池,只有針對此對象調用notify()方法后本線程才進入對象鎖定池准備,獲取對象鎖進入運行狀態。