本文利用AtomicLong實作了一個安全高效的計數器,利用線程池技術,測試結果符合預期,避免了線程并發操作變量問題,避免使用同步鎖提高了效率。
package com.springapp.mvc;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.atomic.AtomicLong;
/**
* Created by acer on 2017/5/27.
*/
public class TestAtomic {
//AtomicLong 的api參考 http://www.tuicool.com/articles/uY3qIbB
public static final AtomicLong atomicLong = new AtomicLong(0L);
public static void main(String[] args) {
ExecutorService executorService = Executors.newFixedThreadPool(10);
MyThread myThread = null;
for(int i = 0;i<100;i++){
myThread = new MyThread(atomicLong);
//ExecutorService的api中文解釋【啟動一次順序關閉,執行以前送出的任務,但不接受新任務】 http://tool.oschina.net/apidocs/apidoc?api=jdk-zh
executorService.submit(myThread);
}
executorService.shutdown();
System.out.println(atomicLong.get());
}
}
class MyThread extends Thread {
private AtomicLong atomicLong;
public MyThread(AtomicLong atomicLong){
this.atomicLong = atomicLong;
}
@Override
public void run() {
System.out.println(Thread.currentThread().getName() + "正在執行。。。");
System.out.println(atomicLong.incrementAndGet());
}
}