如何執行緒安全地實現一個計數器(不看後悔,看了必懂)
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
@Override
public void run() {
while (true) {
try {
Thread.sleep(1);
} catch (InterruptedException e) {
e.printStackTrace();
}
MySafeThread.calc();
}
}
private synchronized static
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();
}
}
}