我刚刚遇到了 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;
}
}
有人可以澄清这一点吗?
每次对它进行 ++ 时,syncObject 都会发生变化(++ 将其转换为原始 int,递增它,然后将其自动装箱回 Integer 对象。Integer 对象是不可变的......一旦创建,它们就无法更改。
最重要的是,您没有在所有线程中使用相同的syncPObj,不同的线程在不同的时间使用不同的syncObjects进行同步。
使用一个对象作为同步(称为syncObj),并将其声明为最终对象:
private static final Object syncObject = new Object();
那么你的计数器应该是一个原语(int)以提高性能,称之为“计数器”或其他什么。
在syncObject上同步,并递增计数器。
编辑:根据@jsn,done 标志也被破坏,因为您的代码在 isAllDone() 方法上有一个“紧密循环”,这是不好的做法。您应该使用 thread[i].join() 等待(阻塞)每个线程的完成,然后检查状态。使用 ExecutorService 是“正确的方法”。
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)