线程通信的方法

程序在使用多线程执行任务时，经常需要线程之间协同工作。此时，我们需要了解线程通信的手段。

线程通信大致分为以下四类：

文件共享
网络共享
共享变量
JDK提供的线程协调API

本文主要研究第四类，如何使用JDK提供的API正确地阻塞、唤醒目标线程。

Thread#suspend()和Thread#resume()

Thread#suspend()：挂起目标线程不再继续执行，直到它被resume()唤醒。

Thread#resume()：如果目标线程已被挂起，那么唤醒目标线程并允许它继续执行。

举个栗子:

public class ThreadCommunication {

    private static volatile Object steamedStuffedBun;

    // 正常的suspend/resume
    private static void suspendResume() throws InterruptedException {
        Thread thread = new Thread(new Runnable() {
            public void run() {
                while (steamedStuffedBun == null) {
                    System.out.println("没有包子，进入等待");
                    // 挂起当前线程
                    Thread.currentThread().suspend();
                }
                System.out.println("买到包子，回家");
            }
        });
        thread.start();
        // 3s后生产一个包子
        Thread.sleep(3000);
        steamedStuffedBun = new Object();
        System.out.println("包子做好了");
        // 唤醒目标线程
        thread.resume();
        thread.join();
    }
    
    public static void main(String[] args) throws InterruptedException {
        suspendResume();
    }    
}

运行main()方法，控制台输出如下：

没有包子，进入等待
包子做好了
买到包子，回家

suspend()和resume()帮助我们在适当的时候阻塞和唤醒线程，成功地模拟了顾客在包子店买包子的情景。

但是，这对API在JDK1.2之后被弃用，原因是它们特别容易形成死锁。

如果目标线程持有监视器锁，在调用suspend()挂起目标线程时并不会释放这把锁。此时，如果其他线程在调用目标线程的resume()方法之前也要先获取这把锁，死锁就产生了。

public class ThreadCommunication {

    private static volatile Object steamedStuffedBun;

    // 会死锁的suspend/resume
    private static void suspendResumeDeadLock() throws InterruptedException {
        final Object lock = new Object();
        Thread thread = new Thread(new Runnable() {
            public void run() {
                while (steamedStuffedBun == null) {
                    System.out.println("没有包子，进入等待");
                    // 当前线程拿到锁，然后挂起
                    synchronized (lock) {
                        Thread.currentThread().suspend();
                    }
                }
                System.out.println("买到包子，回家");
            }
        });
        thread.start();
        // 3s后生产一个包子
        Thread.sleep(3000);
        steamedStuffedBun = new Object();
        // 争取到锁以后再唤醒目标线程
        synchronized (lock) { // 此处会一直BLOCKED
            System.out.println("包子做好了");
            thread.resume();
        }
        thread.join();
    }
    
    public static void main(String[] args) throws InterruptedException {
        suspendResumeDeadLock();
    }    
}

运行main()方法，程序无法退出，控制台输出如下：

没有包子，进入等待

唤醒目标线程的条件已经满足（包子做好了），但是拿不到锁，就无法唤醒目标线程，程序就这样被“冻结”。

即使在不涉及监视器锁的情况下使用suspend()和resume()，如果调用顺序不当，线程也可能永远挂起。

public class ThreadCommunication {

    private static volatile Object steamedStuffedBun;

    // 会永远挂起的suspend/resume
    private static void suspendForever() throws InterruptedException {
        Thread thread = new Thread(new Runnable() {
            public void run() {
                while (steamedStuffedBun == null) {
                    try {
                        // 睡眠一段时间，让resume()方法先执行
                        Thread.sleep(5000);
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                    System.out.println("没有包子，进入等待");
                    // 挂起当前线程
                    Thread.currentThread().suspend();
                }
                System.out.println("买到包子，回家");
            }
        });
        thread.start();
        // 3s后生产一个包子
        Thread.sleep(3000);
        steamedStuffedBun = new Object();
        System.out.println("包子做好了");
        // 唤醒目标线程（此时线程还未挂起）
        thread.resume();
        thread.join();
    }
    
    public static void main(String[] args) throws InterruptedException {
        suspendForever();
    }    
}

运行main()方法，程序无法退出，控制台输出如下：

包子做好了
没有包子，进入等待

上面的例子中，resume()在suspend()之前被调用，目标线程被挂起之后，没有线程来调用resume()唤醒它，就会永远挂起。

既然Thread#suspend()和Thread#resume()已经被弃用，那就让我们来看看它们的替代方法吧。

Object#wait()和Object#notify()/Object#notifyAll()

调用以下方法时，当前线程必须是对象监视器锁的持有者。

Object#wait()：将当前线程放入对象监视器锁的等待集合，释放对象的监视器锁，线程不再被操作系统调度，进入等待直到被唤醒或中断，然后再次竞争获得对象的监视器锁，恢复执行。

Object#notify()：唤醒对象监视器锁等待集合中的任意一个线程。

Object#notifyAll()：唤醒对象监视器锁等待集合中的所有线程。

因此，wait()/notify()只适用于线程持有锁的情境下。

public class ThreadCommunication {

    private static volatile Object steamedStuffedBun;

    private static void waitNotify() throws InterruptedException {
        final Object lock = new Object();
        Thread thread = new Thread(new Runnable() {
            public void run() {
                while (steamedStuffedBun == null) {
                    synchronized (lock) {
                        try {
                            System.out.println("没有包子，进入等待");
                            lock.wait();
                        } catch (InterruptedException e) {
                            e.printStackTrace();
                        }
                    }
                }
                System.out.println("买到包子，回家");
            }
        });
        thread.start();
        // 3s后生产一个包子
        Thread.sleep(3000);
        steamedStuffedBun = new Object();
        // 通知目标线程
        synchronized (lock) {
            System.out.println("包子做好了");
            lock.notify();
        }
        thread.join();
    }
    
    public static void main(String[] args) throws InterruptedException {
        waitNotify();
    }    
}

运行main()方法，控制台输出如下：

没有包子，进入等待
包子做好了
买到包子，回家

wait()/notify帮助我们成功地买到了包子。

与suspend()/resume()相似，wait()/notify()如果调用顺序不当，也会造成线程无法被唤醒：

public class ThreadCommunication {

    private static volatile Object steamedStuffedBun;

    private static void waitForever() throws InterruptedException {
        final Object lock = new Object();
        Thread thread = new Thread(new Runnable() {
            public void run() {
                while (steamedStuffedBun == null) {
                    try {
                        // 睡眠一段时间，让notify()先执行
                        Thread.sleep(5000);
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                    synchronized (lock) {
                        try {
                            System.out.println("没有包子，进入等待");
                            lock.wait();
                        } catch (InterruptedException e) {
                            e.printStackTrace();
                        }
                    }
                }
                System.out.println("买到包子，回家");
            }
        });
        thread.start();
        // 3s后生产一个包子
        Thread.sleep(3000);
        steamedStuffedBun = new Object();
        // 通知目标线程
        synchronized (lock) {
            System.out.println("包子做好了");
            lock.notify();
        }
        thread.join();
    }
    
    public static void main(String[] args) throws InterruptedException {
        waitForever();
    }    
}

运行main()方法，程序无法退出，控制台输出如下：

包子做好了
没有包子，进入等待

目标线程的notify()方法先于wait()方法被调用，导致wait()方法被调用后没有线程来唤醒它，就会一直处于WAITING状态。

LockSupport#park()和LockSupport#unpark()

与wait()/notify()不同，park()/unpark()调用时线程不用获取对象的监视器锁。

LockSupport#park()：禁止当前线程进行线程调度，直到许可证可用。如果当前许可证可用，那么消费该许可证，本地调用立刻返回。

LockSupport#unpark()：如果目标线程许可证不可用，则为其提供许可证。否则，目标线程的下一次park()调用不会阻塞。

可以看出，park()与unpark()为线程维护了一个许可证，该许可证只有可用/不可用两种状态（默认不可用）。unpark()将许可证置为可用。而park()在许可证不可用的时候阻塞，在许可证可用的时候消费该许可证（将其置为不可用）然后立即返回。因此，park()能否从阻塞中恢复与park()/unpark()的调用顺序无关。

public class ThreadCommunication {

    private static volatile Object steamedStuffedBun;

    private static void parkUnpark() throws InterruptedException {
        Thread thread = new Thread(new Runnable() {
            public void run() {
                while (steamedStuffedBun == null) {
                    System.out.println("没有包子，进入等待");
                    // 挂起当前线程
                    LockSupport.park();
                }
                System.out.println("买到包子，回家");
            }
        });
        thread.start();
        // 3s后生产一个包子
        Thread.sleep(3000);
        steamedStuffedBun = new Object();
        System.out.println("包子做好了");
        // 唤醒目标线程
        LockSupport.unpark(thread);
        thread.join();
    }
    
    public static void main(String[] args) throws InterruptedException {
        parkUnpark();
    }  
}

运行main()方法，控制台输出如下：

没有包子，进入等待
包子做好了
买到包子，回家

虽然park()/unpark()没有调用顺序的要求，但是如果在调用park()时，当前线程已经持有了对象的监视器锁，park()不会释放该锁。此时，如果在调用unpark()前也需要获取对象的监视器锁，就会死锁。

public class ThreadCommunication {

    private static volatile Object steamedStuffedBun;

    private static void parkUnparkDeadLock() throws InterruptedException {
        final Object lock = new Object();
        Thread thread = new Thread(new Runnable() {
            public void run() {
                while (steamedStuffedBun == null) {
                    synchronized (lock) {
                        System.out.println("没有包子，进入等待");
                        // 挂起当前线程，但是不会释放锁
                        LockSupport.park();
                    }
                }
                System.out.println("买到包子，回家");
            }
        });
        thread.start();
        // 3s后生产一个包子
        Thread.sleep(3000);
        steamedStuffedBun = new Object();
        // 先拿到锁，再唤醒目标线程
        // 但是锁现在被park()线程持有，此处一直BLOCKED，死锁了
        synchronized (lock) {
            System.out.println("包子做好了");
            LockSupport.unpark(thread);
        }
        thread.join();
    }
    
    public static void main(String[] args) throws InterruptedException {
        parkUnparkDeadLock();
    }  
}

注意：wait()和park()都有可能被伪唤醒，建议在循环中检查等待/挂起条件，防止程序在不满足结束条件的情况下退出。

人面猴
序言：七十年代末，一起剥皮案震惊了整个滨河市，随后出现的几起案子，更是在滨河造成了极大的恐慌，老刑警刘岩，带你破解...
沈念sama阅读 194,088评论 5赞 459
死咒
序言：滨河连续发生了三起死亡事件，死亡现场离奇诡异，居然都是意外死亡，警方通过查阅死者的电脑和手机，发现死者居然都...
沈念sama阅读 81,715评论 2赞 371
救了他两次的神仙让他今天三更去死
文/潘晓璐我一进店门，熙熙楼的掌柜王于贵愁眉苦脸地迎上来，“玉大人，你说我怎么就摊上这事。” “怎么了？”我有些...
开封第一讲书人阅读 141,361评论 0赞 319
道士缉凶录：失踪的卖姜人
文/不坏的土叔我叫张陵，是天一观的道长。经常有香客问我，道长，这世上最难降的妖魔是什么？我笑而不...
开封第一讲书人阅读 52,099评论 1赞 263
港岛之恋（遗憾婚礼）
正文为了忘掉前任，我火速办了婚礼，结果婚礼上，老公的妹妹穿的比我还像新娘。我一直安慰自己，他们只是感情好，可当我...
茶点故事阅读 60,987评论 4赞 355
恶毒庶女顶嫁案：这布局不是一般人想出来的
文/花漫我一把揭开白布。她就那样静静地躺着，像睡着了一般。火红的嫁衣衬着肌肤如雪。梳的纹丝不乱的头发上，一...
开封第一讲书人阅读 46,063评论 1赞 272
城市分裂传说
那天，我揣着相机与录音，去河边找鬼。笑死，一个胖子当着我的面吹牛，可吹牛的内容都是我干的。我是一名探鬼主播，决...
沈念sama阅读 36,486评论 3赞 381
双鸳鸯连环套：你想象不到人心有多黑
文/苍兰香墨我猛地睁开眼，长吁一口气：“原来是场噩梦啊……” “哼！你这毒妇竟也来了？” 一声冷哼从身侧响起，我...
开封第一讲书人阅读 35,175评论 0赞 253
万荣杀人案实录
序言：老挝万荣一对情侣失踪，失踪者是张志新（化名）和其女友刘颖，没想到半个月后，有当地人在树林里发现了一具尸体，经...
沈念sama阅读 39,440评论 1赞 290
护林员之死
正文独居荒郊野岭守林人离奇死亡，尸身上长有42处带血的脓包…… 初始之章·张勋以下内容为张勋视角年9月15日...
茶点故事阅读 34,518评论 2赞 309
白月光启示录
正文我和宋清朗相恋三年，在试婚纱的时候发现自己被绿了。大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
茶点故事阅读 36,305评论 1赞 326
活死人
序言：一个原本活蹦乱跳的男人离奇死亡，死状恐怖，灵堂内的尸体忽然破棺而出，到底是诈尸还是另有隐情，我是刑警宁泽，带...
沈念sama阅读 32,190评论 3赞 312
日本核电站爆炸内幕
正文年R本政府宣布，位于F岛的核电站，受9级特大地震影响，放射性物质发生泄漏。R本人自食恶果不足惜，却给世界环境...
茶点故事阅读 37,550评论 3赞 298
男人毒药：我在死后第九天来索命
文/蒙蒙一、第九天我趴在偏房一处隐蔽的房顶上张望。院中可真热闹，春花似锦、人声如沸。这庄子的主人今日做“春日...
开封第一讲书人阅读 28,880评论 0赞 17
一桩弑父案，背后竟有这般阴谋
文/苍兰香墨我抬头看了看天上的太阳。三九已至，却和暖如春，着一层夹袄步出监牢的瞬间，已是汗流浃背。一阵脚步声响...
开封第一讲书人阅读 30,152评论 1赞 250
情欲美人皮
我被黑心中介骗来泰国打工，没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留，地道东北人。一个月前我还...
沈念sama阅读 41,451评论 2赞 341
代替公主和亲
正文我出身青楼，却偏偏与公主长得像，于是被迫代替她去往敌国和亲。传闻我的和亲对象是个残疾皇子，可洞房花烛夜当晚...
茶点故事阅读 40,637评论 2赞 335

线程通信的方法

线程通信的方法

Thread#suspend()和Thread#resume()

Object#wait()和Object#notify()/Object#notifyAll()

LockSupport#park()和LockSupport#unpark()

推荐阅读更多精彩内容