1. 程式人生 > >如何執行緒安全地實現一個計數器(不看後悔,看了必懂)

如何執行緒安全地實現一個計數器(不看後悔,看了必懂)

i++是執行緒安全的嗎

 

i++和++i的執行緒安全分為兩種情況:

1、如果i是區域性變數(在方法裡定義的),那麼是執行緒安全的。因為區域性變數是執行緒私有的,別的執行緒訪問不到,其實也可以說沒有執行緒安不安全之說,因為別的執行緒對他造不成影響。

2、如果i是全域性變數(類的成員變數),那麼是執行緒不安全的。因為如果是全域性變數的話,同一程序中的不同執行緒都有可能訪問到。

如何執行緒安全地實現一個計數器

或者這樣問:有5個執行緒,每個執行緒作自增到1000

Java 提供了一組atomic class來幫助我們簡化同步處理。基本工作原理是使用了同步synchronized的方法實現了對一個long, integer, 物件的增、減、賦值(更新)操作. 

import java.util.concurrent.atomic.AtomicInteger;

 

/**

 * 編寫一個執行緒安全的計數器

 * 5個執行緒一起跑,輸出執行緒和計數到1000

 * @author yadid

 *

 */

public class MySafeThread implements Runnable {

// 設定計數初值為0

private static AtomicInteger

 count = new AtomicInteger(0);

 

@Override

public void run() {

while (true) {

try {

Thread.sleep(1);

} catch (InterruptedException e) {

e.printStackTrace();

}

MySafeThread.calc();

}

 

}

private synchronized static

 void calc() {

if (count.get() < 1000) {

// 自增1,返回更新後的值

int c = count.incrementAndGet();

System.out.println("執行緒:" + Thread.currentThread().getName()+" :" + c);

}

}

 

public static void main(String[] args) {

for (int i = 0; i < 5; i++) {

MySafeThread myThread = new MySafeThread();

Thread t = new Thread(myThread);

t.start();

}

}

}