多個線程之間共享數據的方式探討

時間 2019-11-12

標籤多個線程之間共享數據方式探討简体版

原文原文鏈接

1、概述

一、若是每一個線程執行的代碼相同，可使用同一個Runnable對象，這個Runnable對象中有那個共享數據，例如，買票系統就能夠這麼作。java

/** 
* @Title: TicketSoldThreadTest.java 
* @Package com.lh.threadtest.t7 
* @Description: TODO
* @author Liu 
* @date 2018年1月17日 上午9:58:08 
* @version V1.0 
*/
package com.lh.threadtest.t7;

/** 
* @ClassName: TicketSoldThreadTest 
* @Description: 多個線程之間共享數據的方式探討
* 
* 若是每一個線程執行的代碼相同，可使用同一個Runnable對象，這個Runnable對象中有那個共享數據。
* 例如，買票系統就能夠這麼作
* 
* @author Liu
* @date 2018年1月17日 上午9:58:08 
*  
*/
public class TicketSoldThreadTest {

	/***
	* @Title: main 
	* @Description: TODO
	* @param @param args
	* @return void
	* @throws 
	*/
	public static void main(String[] args) {
		TicketSoldBusiness ticketSoldBusiness = new TicketSoldBusiness();
		for(int i = 0; i < 2; i++){
			new Thread(ticketSoldBusiness).start();
		}
		
	}

}

class TicketSoldBusiness implements Runnable{
	private int count = 10;
	
	private void dec(){
		count--;
		System.out.println(Thread.currentThread().getName() + " count: " + count);
	}

	/* (非 Javadoc) 
	* <p>Title: run</p> 
	* <p>Description: </p>  
	* @see java.lang.Runnable#run() 
	*/
	@Override
	public void run() {
		while(count > 0){
			dec();
		}
	}
	
}

二、若是每一個線程執行的代碼不一樣，這時候須要用不一樣的Runnable對象，有以下兩種方式來實現這些Runnable對象之間的數據共享：ide

① 將共享數據封裝在另一個對象中，而後將這個對象逐一傳遞給各個Runnable對象。每一個線程對共享數據的操做方法也分配到那個對象身上去完成，這樣容易實現針對該數據進行的各個操做的互斥和通訊。this

/** 
* @Title: MultiThreadShareData.java 
* @Package com.lh.threadtest.t7 
* @Description: TODO
* @author Liu 
* @date 2018年1月16日 下午9:45:37 
* @version V1.0 
*/
package com.lh.threadtest.t7;

/** 
* @ClassName: MultiThreadShareData 
* @Description: 多個線程之間共享數據的方式探討
* 
* 題目：
* 	設計4個線程，其中兩個線程每次對j增長1，另外兩個線程對j每次都減小1，寫出程序。
* 
* @author Liu
* @date 2018年1月16日 下午9:45:37 
*  
*/
public class MultiThreadShareData2 {
	
	/***
	* @Title: main 
	* @Description: TODO
	* @param @param args
	* @return void
	* @throws 
	*/
	public static void main(String[] args) {
		Business business = new Business();
		
		for(int i = 0; i< 2; i++){
			new Thread(new Inc(business)).start();
			new Thread(new Dec(business)).start();
		}
	}
}

class Inc implements Runnable{
	private Business business;

	public Inc(Business business){
		this.business = business;
	}

	/* (非 Javadoc) 
	* <p>Title: run</p> 
	* <p>Description: </p>  
	* @see java.lang.Runnable#run() 
	*/
	@Override
	public void run() {
		for(int i = 0; i< 5; i++){
			this.business.inc();
		}
	}
	
}

class Dec implements Runnable{
	private Business business;
	
	public Dec(Business business){
		this.business = business;
	}
	
	/* (非 Javadoc) 
	 * <p>Title: run</p> 
	 * <p>Description: </p>  
	 * @see java.lang.Runnable#run() 
	 */
	@Override
	public void run() {
		for(int i = 0; i< 5; i++){
			this.business.dec();
		}
	}
	
}

class Business{
	private int j = 0;
	
	public synchronized void inc(){
		j++;
		System.out.println(Thread.currentThread().getName() + "中 j = " + j);
	}
	
	public synchronized void dec(){
		j--;
		System.out.println(Thread.currentThread().getName() + "中 j = " + j);
	}
}

② 將這些Runnable對象做爲某一個類中的內部類，共享數據做爲這個外部類中的成員變量，每一個線程對共享數據的操做方法也分配給外部類，以便實現對共享數據進行的各個操做的互斥和通訊，做爲內部類的各個Runnable對象調用外部類的這些方法。spa

/** 
* @Title: MultiThreadShareData.java 
* @Package com.lh.threadtest.t7 
* @Description: TODO
* @author Liu 
* @date 2018年1月16日 下午9:45:37 
* @version V1.0 
*/
package com.lh.threadtest.t7;

/** 
* @ClassName: MultiThreadShareData 
* @Description: 多個線程之間共享數據的方式探討
* 
* 題目：
* 	設計4個線程，其中兩個線程每次對j增長1，另外兩個線程對j每次都減小1，寫出程序。
* 
* @author Liu
* @date 2018年1月16日 下午9:45:37 
*  
*/
public class MultiThreadShareData {
	private int j = 0;
	
	public synchronized void inc(){
		j++;
		System.out.println(Thread.currentThread().getName() + "中 j = " + j);
	}
	
	public synchronized void dec(){
		j--;
		System.out.println(Thread.currentThread().getName() + "中 j = " + j);
	}
	
	/***
	* @Title: main 
	* @Description: TODO
	* @param @param args
	* @return void
	* @throws 
	*/
	public static void main(String[] args) {
		MultiThreadShareData multiThreadShareData = new MultiThreadShareData();
		for(int i = 0; i< 2; i++){
			new Thread(multiThreadShareData.new IncBusiness()).start();
			new Thread(multiThreadShareData.new DecBusiness()).start();
		}
	}
	
	class IncBusiness implements Runnable{

		/* (非 Javadoc) 
		* <p>Title: run</p> 
		* <p>Description: </p>  
		* @see java.lang.Runnable#run() 
		*/
		@Override
		public void run() {
			for(int i = 0; i< 5; i++){
				inc();
			}
		}
		
	}
	
	class DecBusiness implements Runnable{
		
		/* (非 Javadoc) 
		 * <p>Title: run</p> 
		 * <p>Description: </p>  
		 * @see java.lang.Runnable#run() 
		 */
		@Override
		public void run() {
			for(int i = 0; i< 5; i++){
				dec();
			}
		}
		
	}

}

③ 上面兩種方式的組合：將共享數據封裝在另一個對象中，每一個線程對共享數據的操做方法也分配到那個對象身上去完成，對象做爲這個外部類中的成員變量或方法中的局部變量，每一個線程的Runnable對象做爲外部類中的成員內部類或局部內部類。線程

④ 總之，要同步互斥的幾段代碼最好是分別放在幾個獨立的方法中，這些方法再放在同一個類中，這樣比較容易實現它們之間的同步互斥和通訊。設計

/** 
* @Title: MultiThreadShareData.java 
* @Package com.lh.threadtest.t7 
* @Description: TODO
* @author Liu 
* @date 2018年1月16日 下午9:45:37 
* @version V1.0 
*/
package com.lh.threadtest.t7;

/** 
* @ClassName: MultiThreadShareData 
* @Description: 多個線程之間共享數據的方式探討
* 
* 題目：
* 	設計4個線程，其中兩個線程每次對j增長1，另外兩個線程對j每次都減小1，寫出程序。
* 
* @author Liu
* @date 2018年1月16日 下午9:45:37 
*  
*/
public class MultiThreadShareData3 {
	
	/***
	* @Title: main 
	* @Description: TODO
	* @param @param args
	* @return void
	* @throws 
	*/
	public static void main(String[] args) {
		BusinessHandler business = new BusinessHandler();
		
		for(int i = 0; i< 2; i++){
			new Thread(new Runnable() {
				
				@Override
				public void run() {
					business.inc();
				}
			}).start();
			new Thread(new Runnable() {
				
				@Override
				public void run() {
					business.dec();
				}
			}).start();
		}
	}
}

class BusinessHandler{
	private int j = 0;
	
	public synchronized void inc(){
		j++;
		System.out.println(Thread.currentThread().getName() + "中 j = " + j);
	}
	
	public synchronized void dec(){
		j--;
		System.out.println(Thread.currentThread().getName() + "中 j = " + j);
	}
}

三、極端且簡單的方式，即在任意一個類中定義一個static的變量，這將被全部線程共享。code