2

我刚刚在 Java 中遇到了同步块，并编写了一个小程序来测试它是如何工作的。

我创建了 10 个线程，并让每个线程将一个 Integer 对象递增 1000 次。

因此，对于同步，我会假设所有线程完成工作后的结果为 10000，而没有同步的结果小于 10000。

但是，同步并不像我预期的那样工作。

我想这与对象的不变性有关。

我的程序：

public class SyncTest extends Thread{

    private static Integer syncObj = new Integer(0);
    private static SyncTest[] threads = new SyncTest[10];

    private boolean done = false;

    public void run(){
        for(int i = 0; i < 1000; i++){
            synchronized(syncObj){
                syncObj ++;
            }
        }
        done = true;
    }

    public static void main(String[] args) {

        for(int i=0; i < threads.length; i++){
            threads[i] = new SyncTest();
            threads[i].start();
        }

        while(!allDone()); //wait until all threads finished

        System.out.println(syncObj);
    }

    private static boolean allDone(){
        boolean done = true;
        for(int i = 0; i < threads.length; i++){
            done &= threads[i].done; 
        }

        return done;
    }
}

有人可以澄清一下吗？

4

3 回答 3

13

每次 ++ 时，syncObject 都会发生变化（++ 将其转换为原始 int，递增，然后将其自动装箱回 Integer 对象。整数对象是不可变的……一旦创建，它们就无法更改。

底线是您没有在所有线程中使用相同的syncPObj，不同的线程在不同的时间使用不同的syncObjects 来同步。

使用一个对象作为同步对象（称为syncObj），并将其声明为最终对象：

private static final Object syncObject = new Object();

那么你的计数器应该是性能的原始（int），称之为“计数器”或其他东西。

在 syncObject 上同步，并增加计数器。

编辑：根据@jsn，done 标志也被破坏，因为您的代码在 isAllDone() 方法上有一个“紧密循环”，这是不好的做法。您应该使用 thread[i].join() 等待（阻塞）每个线程的完成，然后从中检查状态。使用 ExecutorService 是“正确的方法”。

于 2013-04-29T14:11:49.193 回答
2

假设这是因为 Integer 对象的不变性。

我已将同步块更改为

Integer old = syncObj;
syncObj ++;
System.out.println(syncObj == old);

我的控制台充满了falses

所以每次我增加Integer一个新对象时都会创建一个。

因此我只从旧对象中读取，它不会被锁定。

于 2013-04-29T14:12:43.207 回答
1

这些操作通常使用Atomic. 看看这里。这些结构专为多线程计算而设计。正常的实现不是线程安全的。

于 2013-04-29T14:07:10.700 回答