我有一个“计数器”类,它递增一个计数器直到达到极限。我创建了这个类的 N 个实例,每个类都会增加计数器直到 MAX_COUNT/N。我已经实现了同步方法,但计数器从未达到 MAX_COUNT 值(我将发布代码,这将有助于理解问题)
主.java
package monitores;
// MAIN PROGRAM, IT CREATES THE THREADS, RUNS THEM AND JOINS, AT THE END
// DISPLAYS THE COUNTER VALUE
public class Main {
public static void main(String[] args) throws InterruptedException {
Hilo hilos[] = new Hilo[Hilo.NUM_THREADS];
for(int i = 0; i < Hilo.NUM_THREADS; i++){
hilos[i] = new Hilo();
hilos[i].start();
}
for(int i = 0; i < Hilo.NUM_THREADS; i++){
hilos[i].join();
}
System.out.println("Counter value at the end: "+Hilo.count());
}
}
希洛.java
package monitores;
public class Hilo extends Thread {
public static final int MAX_COUNT = 40000;
public static final int NUM_THREADS = 4;
private static volatile int count = 0;
public static int count() {
return count;
}
@Override
public void run() {
int max = MAX_COUNT / NUM_THREADS;
for (int i = 0; i < max; i++) {
synchronized(this){
count++;
}
}
}
}
如果我运行 Main.java,结果如下:
Counter value at the end: 33870
这是一个随机数,但总是接近 MAX_COUNT。
提前谢谢你。
最佳答案
您的线程仅在自身上同步。他们所做的只是锁定自己并递增,因此代码不是线程安全的。
他们需要在一个公共(public)对象上同步。在这种情况下,.class
对象是合理的。每个线程都可以轻松访问要锁定的单个对象:
synchronized(Hilo.class){
count++;
}
另一种方法是不同步,而是用 AtomicInteger
替换 count
的数据类型.使用 getAndIncrement()
增加。
关于java - Java 线程和同步问题,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/19796923/