【多線程 3】多線程間的變量共享方式


上篇博客說到了多線程的創建方式,本篇博客說說自己對於多個線程間的共享變量的理解。

一、概述

首先,分析集中不同的變量共享場景:

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()方法后本線程才進入對象鎖定池准備,獲取對象鎖進入運行狀態。


 


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM