CAS AtomicInteger 無鎖執行緒安全整數類
阿新 • • 發佈:2019-01-09
import java.util.concurrent.atomic.AtomicInteger; /** * @Auther: zch * @Date: 2019/1/8 15:03 * @Description: */ public class AtomicIntegerDemo { static AtomicInteger i = new AtomicInteger(); public static class AddThread implements Runnable { @Override public void run() { for (int k = 0; k < 10000; k++) { i.incrementAndGet(); } } } public static void main(String[] args) throws InterruptedException { Thread[] ts = new Thread[10]; for (int k=0;k<10;k++) { ts[k] = new Thread(new AddThread()); } for (int k=0;k<10;k++) { ts[k].start(); } for (int k=0;k<10;k++) { ts[k].join(); } System.out.println(i); } }