併發程式設計--volatile
volatile-說明
volatile關鍵字的作用是變數在多個執行緒可見;
volatile 關鍵字是非原子性的
要是實現原子性操作,建議使用atomic類的系列物件:支援原子性操作(注意atomic類只保證本身方法的原子性,並不保證多次操作的原子性)
1. volatile :
volatile關鍵字的作用是變數在多個執行緒可見;
示例:RunThread.java
說明:在Java中,每個執行緒都會有一個工作記憶體區域,其中存放所有執行緒共享的主記憶體中的變數的值得拷貝。當執行緒執行的時候,在自己的工作記憶體區域中操作這些變數。為了存取一個共享的變數,一個執行緒通常先獲得鎖定並清除當前執行緒的記憶體工作區域,把這些共享變數從所有執行緒的共享記憶體區域中正確的裝入到本身所以在的工作記憶體區域中,當執行緒解鎖是保證該工作記憶體中的變數的值寫會到共享記憶體區域中。
* 一個執行緒可以執行的操作有:使用(use),賦值(assgin),裝載(load),儲存(store),鎖定(lock),解鎖(unlock);
* 主記憶體中可以執行的操作有:讀(read),寫(write),鎖定(lock),解鎖(unlock); 每個操作都是原子性的。
* volatile 的作用就是強制執行緒到主記憶體(共享記憶體)中去讀取變數,而不是去執行緒工作記憶體區域裡去讀取,從而實現了多個執行緒間的變數可見。也就滿足了執行緒安全的可見性;
View Code
2. volatile 關鍵字是非原子性的
volatile 關鍵字雖然擁有多個執行緒之間的可見性,但是卻不具備同步性(也就是原子性),可以算是一個輕量級的synchronized,效能要不synchronized強很多,不會造成阻塞(很多開源架構裡面:netty的底層程式碼大量使用可volatile,可見netty效能)
* 需要注意的事:一般volatile用於多個執行緒可見的變數操作,並不能替代synchronized的同步作用;
示例:concurrent.java
說明:volatile 關鍵字只具有可見性,沒有原子性。
1 import java.util.concurrent.atomic.AtomicInteger; 2 /** 3 * volatile關鍵字不具備synchronized關鍵字的原子性(同步) 4 * @@author Maozw 5 * 6 */ 7 public class VolatileNoAtomic extends Thread{ 在此我向大家推薦一個架構學習交流圈:681065582 幫助突破J瓶頸 提升思維能力 8 //private static volatile int count; 9 private static AtomicInteger count = new AtomicInteger(0); 10 private static void addCount(){ 11 for (int i = 0; i < 1000; i++) { 12 //count++ ; 13 count.incrementAndGet(); 14 } 15 System.out.println(count); 16 } 17 18 public void run(){ 19 addCount(); 20 } 21 22 public static void main(String[] args) { 23 24 VolatileNoAtomic[] arr = new VolatileNoAtomic[100]; 25 for (int i = 0; i < 10; i++) { 26 arr[i] = new VolatileNoAtomic(); 27 } 28 29 for (int i = 0; i < 10; i++) { 30 arr[i].start(); 31 } 32 } 33 }
* 要是實現原子性操作,建議使用atomic類的系列物件:支援原子性操作(注意atomic類只保證本身方法的原子性,並不保證多次操作的原子性)
示例:
說明:
1 import java.util.ArrayList; 2 import java.util.List; 3 import java.util.concurrent.atomic.AtomicInteger; 4 5 public class AtomicUse { 6 7 private static AtomicInteger count = new AtomicInteger(0); 8 在此我向大家推薦一個架構學習交流圈:681065582 幫助突破J瓶頸 提升思維能力 9 //多個addAndGet在一個方法內是非原子性的,需要加synchronized進行修飾,保證4個addAndGet整體原子性 10 /**synchronized*/ 11 public synchronized int multiAdd(){ 12 try { 13 Thread.sleep(100); 14 } catch (InterruptedException e) { 15 e.printStackTrace(); 16 } 17 count.addAndGet(1); 18 count.addAndGet(2); 19 count.addAndGet(3); 20 count.addAndGet(4); //+10 21 return count.get(); 22 } 23 public static void main(String[] args) { 24 25 final AtomicUse au = new AtomicUse(); 26 27 List<Thread> ts = new ArrayList<Thread>(); 28 for (int i = 0; i < 100; i++) { 29 ts.add(new Thread(new Runnable() { 30 @Override 31 public void run() { 32 System.out.println(au.multiAdd()); 33 } 34 })); 35 } 36 for(Thread t : ts){ 37 t.start(); 38 } 39 } 40 }