先描述下运行环境,jre1.8.0
代码比较简单,一个简单的线程同步测试demo,但是发送了一些让人难以理解的情况
public class Test {
public static void main(String[] args) {
MyCounter mc = new MyCounter();
MyThread m1 = new MyThread("A",mc);
MyThread m2 = new MyThread("B",mc);
MyThread m3 = new MyThread("C",mc);
MyThread m4 = new MyThread("D",mc);
MyThread m5 = new MyThread("E",mc);
MyThread m6 = new MyThread("F",mc);
m1.start();
m2.start();
m3.start();
m4.start();
m5.start();
m6.start();
}
}
class MyThread extends Thread{
private MyCounter mc = null;
public MyThread(String name,MyCounter mc) {
// TODO Auto-generated constructor stub
super();
this.setName(name);
this.mc = mc;
}
@Override
public void run() {
print();
}
public void print(){
mc.print();
}
}
class MyCounter{
private int count = 10;
public void print(){
count--;
System.out.println(Thread.currentThread().getName()+" count="+count);
}
}
以上代码是没有任何加锁的
运行结果符合预期
然后在MyThread的run方法和print方法分别加锁
结果线程并没同步
只有对MyCounter的print方法加锁才有效果
这就让我很难理解,按道理我在run方法加锁的话,同一时刻执行run方法的线程只能有一个,其调用的方法也应该这样,应该不会产生这种不同步的情况才对。
于是我想是不是线程run方法有特殊情况,于是在MyThread类中另封了一个print方法,对它加锁也没用,还用了加锁代码块的形式测试了一下,也不行
只有在MyCounter的print方法中加锁才有线程同步的效果
这种现象因为不好描述,网上也没搜到想要的答案,希望哪位前辈能帮忙解释一下,多谢!
问题已解决,谢谢大家。
解释如下,加锁用的锁对象是instance,应该以单一的counter instance做锁对象,而以不同的thread instance做锁对象就没有用。
下面的代码是改进后能正确同步的代码
我在run方法加锁的话,同一时刻执行run方法的线程只能有一个
这个认识是错的。一个synchronized的instance method以instance本身为锁。而一个MyThread instance 的run方法本就只被运行一次,加不加synchronized不影响实际行为。想清楚目的: 使用互斥是为了保护数据。如果你要保护一个MyCounter instance内部的数据,直接的做法也应该是在那个MyCounter instance (或与其等价或更小的层面) 加锁。