java - Java 线程和同步问题

Question

我有一个“计数器”类，它递增一个计数器直到达到极限。我创建了这个类的 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。

提前谢谢你。

Answer 1

您的线程仅在自身上同步。他们所做的只是锁定自己并递增，因此代码不是线程安全的。

他们需要在一个公共(public)对象上同步。在这种情况下，.class 对象是合理的。每个线程都可以轻松访问要锁定的单个对象:

synchronized(Hilo.class){
    count++;
}

另一种方法是不同步，而是用 AtomicInteger 替换 count 的数据类型.使用 getAndIncrement() 增加。