各位看看我这个为什么不能保证共享变量线程安全

import java.util.concurrent.atomic.AtomicInteger;

class Test extends Thread {
    private static volatile AtomicInteger initNumber = new AtomicInteger(0);
    private int maxNumber = 8000;

    @Override
    public void run() {
        if (initNumber.get() < maxNumber) {
            initNumber.incrementAndGet();
        } else if (initNumber.get() >= maxNumber) {
            initNumber.set(1);
        }
        System.out.println(initNumber.get());
    }

    public static void main(String[] args) {
        for (int i = 0; i < 10000; i++) {
            Thread thread = new Thread(new Test());
            thread.start();
        }
    }
}

线程类要实现Runable接口,共享变量才能确保线程安全。

 

import java.util.concurrent.atomic.AtomicInteger;

class Test implements Runnable {
    private static volatile AtomicInteger initNumber = new AtomicInteger(0);
    private int maxNumber = 8000;

    @Override
    public void run() {
        if (initNumber.get() < maxNumber) {
            initNumber.incrementAndGet();
        } else if (initNumber.get() >= maxNumber) {
            initNumber.set(1);
        }
        System.out.println(initNumber.get());
    }

    public static void main(String[] args) {
        Test test = new Test();
        for (int i = 0; i < 10000; i++) {
            Thread thread = new Thread(test);
            thread.start();
        }
    }
}

 

您好,我是有问必答小助手,您的问题已经有小伙伴解答了,您看下是否解决,可以追评进行沟通哦~

如果有您比较满意的答案 / 帮您提供解决思路的答案,可以点击【采纳】按钮,给回答的小伙伴一些鼓励哦~~

ps:问答VIP仅需29元,即可享受5次/月 有问必答服务,了解详情>>>https://vip.csdn.net/askvip?utm_source=1146287632