1

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

先感谢您。

4

3 回答 3

3

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

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

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

另一种方法不是同步，而是count用AtomicInteger. 增加getAndIncrement().

于 2013-11-05T19:16:04.170 回答
0

这闻起来像比赛条件。如果每次都有随机值，这意味着不同的线程在同一时刻写入同一个变量。

如果我有两个线程，您需要同步共享变量或创建一个它们都需要用来更新计数的同步方法。

于 2013-11-05T19:17:28.833 回答
0

但计数器永远不会达到 MAX_COUNT 值（我将发布代码，这将有助于理解问题）

问题在于@rgettman 提到您正在同步this每个线程而不是共享对象，例如类。

另一种解决方案是切换到使用AtomicInteger它为您处理同步和内存共享：

private static AtomicInteger count = new AtomicInteger(0);
...
public static int count() {
    return count.get();
}
...
for (int i = 0; i < max; i++) {
    // no need for synchronization object here
    count.incrementAndGet();
}
于 2013-11-05T19:18:43.200 回答