线程交替打印数字

线程交替打印数字是一道典型的面试题,主要考察对象锁的使用、锁状态、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() {}
    }
指向同一个对象
©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 204,445评论 6 478
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 85,889评论 2 381
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 151,047评论 0 337
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 54,760评论 1 276
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 63,745评论 5 367
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 48,638评论 1 281
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 38,011评论 3 398
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 36,669评论 0 258
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 40,923评论 1 299
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 35,655评论 2 321
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 37,740评论 1 330
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 33,406评论 4 320
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 38,995评论 3 307
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 29,961评论 0 19
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 31,197评论 1 260
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 45,023评论 2 350
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 42,483评论 2 342

推荐阅读更多精彩内容

  • Java多线程学习 [-] 一扩展javalangThread类 二实现javalangRunnable接口 三T...
    影驰阅读 2,949评论 1 18
  • 本文主要讲了java中多线程的使用方法、线程同步、线程数据传递、线程状态及相应的一些线程函数用法、概述等。 首先讲...
    李欣阳阅读 2,438评论 1 15
  • 整理来自互联网 1,JDK:Java Development Kit,java的开发和运行环境,java的开发工具...
    Ncompass阅读 1,534评论 0 6
  • 一:java概述: 1,JDK:Java Development Kit,java的开发和运行环境,java的开发...
    慕容小伟阅读 1,763评论 0 10
  • 一:java概述:1,JDK:Java Development Kit,java的开发和运行环境,java的开发工...
    ZaneInTheSun阅读 2,627评论 0 11