1.如果每個線程執行的代碼相同,可以使用同一個Runnable對象,這個Runnable對象有那個共享數據,例如,買票系統就可以這么做
2.如果每個線程執行的代碼不同,這時候需要使用不同的Runnable對象,有如下3種方式來實現這些Runnalbe對象之間的數據共享:
->方式1: 將共享數據封裝在另外一個對象中,然后將這個對象逐一傳遞給各個Runnable對象,每個線程對共享數據的操作方法也分配到那個對象身上去完成,這樣容易實現針對該數據進行的各個操作的互斥和通信 (理解最簡單)
->方式2:將這些Runable對象作為某一個類中的內部類,共享數據作為這個外部類中的成員變量,每個線程對共享數據的操作方法也分配給外部類,以便實現對共享數據進行各個操作的互斥和通信,作為內部類的各個Runnable對象調用外部類的這些方法
-> 方式3:上面兩種方式的組合:將共享數據封裝在另外一個對象中,每個線程對共享數據的操作方法也分配到那個對象身上去完成,對象作為外部類中的成員變量或方法中的局部變量,每個線程的Runnable對象作為外部類中的成員內部類或局部內部類
總之,要同步互斥的幾段代碼最好是分別放在幾個獨立的方法中 ,這些方法再放在同一個類中,這樣比較容易實現他們之間的同步互斥和通信
示例:設計四個線程,其中兩個線程每次對 count + 1, 另外兩個線程對count -1 (模擬售票,買票)
package com.prepare.study; import sun.security.provider.SHA; /** * @author: yinlm * @Date: Created in 2018/4/18 * @Description:共享數據方式 1 */ public class MultyThreadShareDateTest { public static void main(String[] args){ ShareData shareData = new ShareData(); for(int i=1;i<=2;i++){ new Thread(new MyIncreRunnable(shareData)).start(); new Thread(new MyDecreRunanble(shareData)).start(); } } } class MyIncreRunnable implements Runnable{ private ShareData shareData; public MyIncreRunnable(ShareData shareData) { this.shareData = shareData; } @Override public void run() { for (int i = 1;i<=10;i++){ shareData.increment(); } } } class MyDecreRunanble implements Runnable{ private ShareData shareData; public MyDecreRunanble(ShareData shareData) { this.shareData = shareData; } @Override public void run() { for(int i=1;i<=10;i++){ shareData.decrement(); } } } // 共享數據,對共享數據的操作也在這個對象中完成 class ShareData{ private int count = 0; public synchronized void increment(){ count++; System.out.println(Thread.currentThread().getName()+" inc "+count); } public synchronized void decrement(){ count--; System.out.println(Thread.currentThread().getName()+" dec " +count); } }