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