最近遇到一个crash问题,是关于线程同步锁的,检查代码的时候发现方法已经使用synchronized同步了,为什么还会出现该异常呢?
就想是不是synchronized使用的不对呢?查了些资料发现好像synchronized真用错了!
我们先看一下synchronized的官方定义:
synchronized Java语言的关键字,可用来给对象和方法或者代码块加锁,当它锁定一个方法或者一个代码块的时候,同一时刻最多只有一个线程执行这段代码。
我们先来看一段代码
public class Test {
class DB {
private synchronized void query() {
System.out.println("开始查询");
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
System.out.println("查询结束");
}
}
private static Runnable myRunnable = new Runnable() {
@Override
public void run() {
DB db = new Test().new DB();
db.query();
}
};
public static void main(String[] args) throws Exception {
Thread thread1 = new Thread(myRunnable);
thread1.start();
Thread thread2 = new Thread(myRunnable);
thread2.start();
}
}
我们看下输出结果
开始查询
开始查询
查询结束
查询结束
咦 我的方法已经加了synchronized了,为什么还是用两个线程同时执行了query方法呢?是不是synchronized加错地方了呢?
我们改下代码 把query方法前面的synchronized 去掉 放到方法里面去
private void query() {
synchronized (this) {
System.out.println("开始查询");
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
System.out.println("查询结束");
}
}
这样我锁住这个代码块应该就没问题了吧!我们来看下运行结果
开始查询
开始查询
查询结束
查询结束
恩?怎么还是两个线程同时执行了query方法呢?
想一个问题 synchronized 到底锁住的是方法,是代码块还是对象?
来看下面代码
private void query() {
synchronized (DB.class) {
System.out.println("开始查询");
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
System.out.println("查询结束");
}
}
}
把上面的的synchronized (this)改成 synchronized (DB.class) ,执行程序看下结果
开始查询
查询结束
开始查询
查询结束
终于输出了我们期望的结果。
说下上面的问题,synchronized 锁住的是什么?
synchronized 锁住的是括号里面的对象!
我们回头看下第一段代码把synchronized 加到方法前面,怎么能输出正确的结果?我们改下代码
public class Test {
class DB {
private synchronized void query() {
System.out.println("开始查询");
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
System.out.println("查询结束");
}
}
private static DB db = new Test().new DB();
private static Runnable myRunnable = new Runnable() {
public void run() {
db.query();
}
};
public static void main(String[] args) throws Exception {
Thread thread1 = new Thread(myRunnable);
thread1.start();
Thread thread2 = new Thread(myRunnable);
thread2.start();
}
}
执行程序 看下输出结果
开始查询
查询结束
开始查询
查询结束
程序正常输出
当synchronized加到方法前面时,当有多个线程同时访问 ”同一个对象” 的synchronized方法时,一个时间内只能有一个线程得到执行。另一个线程必须等待当前线程执行完这个方法才能执行。
synchronized有风险,要用需谨慎啊!
网友评论