线程交替打印数字是一道典型的面试题，主要考察对象锁的使用、锁状态、wait和notify的使用，下面记录一下我做这道题的时发现的一些问题。
第一遍的思路是这样，定义一个变量count，既作为计数器，又作为对象锁。
之所以觉得这样可行，见博文《多线程同步与通信》，里面的示例就是把引用对象既作为共享数据，又作为对象锁，事实证明，那个例子这样做可以，这个Integer类型的count不行，这篇文章主要就说这个事——锁对象不能改变。
然后分别写两个线程，在同步代码块内部进行条件判断，对于线程A如果count是偶数，就使用wait()让线程等待，线程A处于等待状态，不会再竞争锁，此时线程B拿到了对象锁，打印完偶数后唤醒线程A。
等待和唤醒都在同步代码块中进行的，应该不会有问题。
代码如下：
package cn.demo.demo01;
public class AlterPrint {
// 用于交替打印的数字, 同时作为锁对象
private static Integer count = 0;
public static void main(String[] args) {
// 线程1打印偶数
Thread t1 = new Thread(new Runnable() {
@Override
public void run() {
while (count < 100) {
synchronized (count) {
if (count % 2 == 1) {
try {
count.wait();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
// count为偶数
System.out.println(Thread.currentThread().getName() + "打印: " + count);
count++;
count.notify();
}
}
}
});
// 线程2打印奇数
Thread t2 = new Thread(new Runnable() {
@Override
public void run() {
while (count < 100) {
synchronized (count) {
if (count % 2 == 0) {
try {
count.wait();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
// count为偶数
System.out.println(Thread.currentThread().getName() + "打印: " + count);
count++;
count.notify();
}
}
}
});
t1.start();
t2.start();
}
}
但是结果抛异常
Thread-0打印: 0
Exception in thread "Thread-0" Thread-1打印: 1
Exception in thread "Thread-1" java.lang.IllegalMonitorStateException
at java.lang.Object.notify(Native Method)
at cn.demo.demo01.AlterPrint$1.run(AlterPrint.java:27)
at java.lang.Thread.run(Thread.java:748)
java.lang.IllegalMonitorStateException
at java.lang.Object.notify(Native Method)
at cn.demo.demo01.AlterPrint$2.run(AlterPrint.java:50)
at java.lang.Thread.run(Thread.java:748)
从结果可以看出，线程A和线程B在调用notify时都出现了IllegalMonitorStateException异常，而出现该异常的原因往往当前线程不是对象锁的持有者。可是明明是在一个同步代码块中，既然能进入同步代码块，说明当前线程持有count，但是这里又说不持有，只能是count发生了改变。
开始我以为Integer这些包装类型跟一般的引用类型一样，其count的值只是该对象的一个实例域，改变count的值不会改变count对象的引用，而实际上在count++前后，通过debug可以看到count的地址发生了改变，也就是说++后的count是一个新的对象，该线程显然不是这个新对象的锁的持有者，因此会报异常。
既然知道了原因，可以使用单独的一个引用对象，大部分答案也是这么处理的：
private static Object object = new Object();
private static Integer count = 0;
使用object的内部锁进行同步，而object从开始到结束都没有改变。
代码如下：
package cn.demo.demo01;
public class demo04 {
// 用于交替打印的数字, 同时作为锁对象
private static Object object = new Object();
private static Integer count = 0;
public static void main(String[] args) {
// 线程1打印偶数
Thread t1 = new Thread(new Runnable() {
@Override
public void run() {
while (count < 100) {
synchronized (object) {
if (count % 2 == 1) {
try {
object.wait();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
// count为偶数
System.out.println(Thread.currentThread().getName() + "打印: " + count);
count++;
object.notify();
}
}
}
});
// 线程2打印奇数
Thread t2 = new Thread(new Runnable() {
@Override
public void run() {
while (count < 100) {
synchronized (object) {
if (count % 2 == 0) {
try {
object.wait();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
// count为偶数
System.out.println(Thread.currentThread().getName() + "打印: " + count);
count++;
object.notify();
}
}
}
});
t1.start();
t2.start();
}
}
番外：那么这些包装类对象到底是什么样的存在呢？通过查阅资料发现，以Integer为例，在首次使用Integer对象时，Integer有一段静态代码块会创建一个池，数值范围是-127~128，当创建的对象的值在这个，从池中选择对应的对象返回给引用，如果再次创建相同值的引用，就会返回相同的对象引用。
private static class IntegerCache {
static final int low = -128;
static final int high;
static final Integer cache[];
static {
// high value may be configured by property
int h = 127;
String integerCacheHighPropValue =
sun.misc.VM.getSavedProperty("java.lang.Integer.IntegerCache.high");
if (integerCacheHighPropValue != null) {
try {
int i = parseInt(integerCacheHighPropValue);
i = Math.max(i, 127);
// Maximum array size is Integer.MAX_VALUE
h = Math.min(i, Integer.MAX_VALUE - (-low) -1);
} catch( NumberFormatException nfe) {
// If the property cannot be parsed into an int, ignore it.
}
}
high = h;
cache = new Integer[(high - low) + 1];
int j = low;
for(int k = 0; k < cache.length; k++)
cache[k] = new Integer(j++);
// range [-128, 127] must be interned (JLS7 5.1.7)
assert IntegerCache.high >= 127;
}
private IntegerCache() {}
}
指向同一个对象
网友评论