新手提问,java多线程的加锁位置问题。

先描述下运行环境,jre1.8.0

clipboard.png

代码比较简单,一个简单的线程同步测试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);
    }
}

以上代码是没有任何加锁的
运行结果符合预期

clipboard.png

然后在MyThread的run方法和print方法分别加锁
结果线程并没同步

clipboard.png

clipboard.png

只有对MyCounter的print方法加锁才有效果

clipboard.png

这就让我很难理解,按道理我在run方法加锁的话,同一时刻执行run方法的线程只能有一个,其调用的方法也应该这样,应该不会产生这种不同步的情况才对。

于是我想是不是线程run方法有特殊情况,于是在MyThread类中另封了一个print方法,对它加锁也没用,还用了加锁代码块的形式测试了一下,也不行

只有在MyCounter的print方法中加锁才有线程同步的效果

这种现象因为不好描述,网上也没搜到想要的答案,希望哪位前辈能帮忙解释一下,多谢!


问题已解决,谢谢大家。

解释如下,加锁用的锁对象是instance,应该以单一的counter instance做锁对象,而以不同的thread instance做锁对象就没有用。

下面的代码是改进后能正确同步的代码

clipboard.png

阅读 3k
2 个回答

我在run方法加锁的话,同一时刻执行run方法的线程只能有一个 这个认识是错的。一个synchronized的instance method以instance本身为锁。而一个MyThread instance 的run方法本就只被运行一次,加不加synchronized不影响实际行为。

想清楚目的: 使用互斥是为了保护数据。如果你要保护一个MyCounter instance内部的数据,直接的做法也应该是在那个MyCounter instance (或与其等价或更小的层面) 加锁。

在run方法加锁的话,同一时刻执行run方法的线程只能有一个,这已经错了,每个线程一个run方法,互不影响好吧.run方法和print都是每个线程都有一个的.

改成一下代码,也可以,对比一下,找找不同.
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 static MyCounter mc = null;

public MyThread(String name, MyCounter mc) {
    super();
    this.setName(name);
    MyThread.mc = mc;
}

@Override
public void run() {
    print();
}

public static synchronized void print() {
    mc.print();
}

}

class MyCounter {

private int count = 10;

public void print() {
    count--;
    System.out.println(Thread.currentThread().getName() + " count=" + count);
}

}

撰写回答
你尚未登录,登录后可以
  • 和开发者交流问题的细节
  • 关注并接收问题和回答的更新提醒
  • 参与内容的编辑和改进,让解决方法与时俱进
推荐问题