首页 > 代码库 > 采用闭锁(CountDownLatch)控制线程的先后顺序(二)

采用闭锁(CountDownLatch)控制线程的先后顺序(二)

还是上一篇的应用场景,将小明与小强持有的闭锁,合二为一,优化后的代码如下:

package com.smikevon.concurrent.tools;import java.util.concurrent.CountDownLatch;/** * @description: 要求:妈妈炒菜,但是这个时候还没买菜,也没有酱油了。为了更快的吃上饭,妈妈,小明,小强,分别行动, *                  妈妈负责敲响做饭铃(铃响之前不许动),兄弟二人就可以出发,然后妈妈收拾厨房调好料,小明负责买菜,小强负责买酱油,协作完成此项工作 * *                  对 TestCountDownLatch_01的一种改进,01中,一个线程就设置一个countDownLatch,这里整体设置一个 * *                 特点:所有的其他线程执行完,执行目标线程(即执行了await的线程) * * @date       : 2014年9月17日 下午2:41:50 */public class TestCountDownLatch_02 {    public static void main(String[] args) {        //响铃的次数        final int BellRingCount = 1;        //需要等待的人(线程)        final int peopleCount = 2;        final CountDownLatch bellRingLatch = new CountDownLatch(BellRingCount);        final CountDownLatch buyLatch = new CountDownLatch(peopleCount);        new Thread(new Runnable() {            public void run() {                try {                    System.out.println("准备做饭了哦!");                    System.out.println("ding ding ding !!!");                    /**                     * 这条代码和下面的顺序颠倒就会导致死锁                     */                    bellRingLatch.countDown();                    //等待菜和酱油都买回来了                    buyLatch.await();                    System.out.println("我是妈妈,菜和酱油都齐了,我开始做饭喽!");                } catch (InterruptedException e) {                    e.printStackTrace();                }            }        },"妈妈").start();        //小明等待铃响就去买菜        new Thread(new Runnable() {            public void run() {                try {                    System.out.println("我是小明,我准备去买菜(to go)!");                    bellRingLatch.await();                    System.out.println("我是小明,我已经买到了菜(get back)!");                } catch (InterruptedException e) {                    e.printStackTrace();                }                buyLatch.countDown();            }        },"小明").start();        new Thread(new Runnable() {            public void run() {                try {                    System.out.println("我是小强,我准备去打酱油(to go)!");                    bellRingLatch.await();                    System.out.println("我是小强,我已经打到了酱油(get back)!");                } catch (InterruptedException e) {                    e.printStackTrace();                }                buyLatch.countDown();            }        },"小强").start();    }}

 

采用闭锁(CountDownLatch)控制线程的先后顺序(二)