黑马程序员技术交流社区

标题: 多线程抽奖 [打印本页]

---

作者: TomZhou    时间: 2016-5-26 19:30
标题: 多线程抽奖
1.同步
        * 使用ReentrantLock类的lock()和unlock()方法进行同步
        * 2.通信
        * 使用ReentrantLock类的newCondition()方法可以获取Condition对象
        * 需要等待的时候使用Condition的await()方法, 唤醒的时候用signal()方法
        * 不同的线程使用不同的Condition, 这样就能区分唤醒的时候找哪个线程了
         */

        public static void main(String[] args) {
                final Print4 p = new Print4();
                new Thread() {
                        public void run() {
                                while (true) {
                                        try {
                                                p.print1();
                                        } catch (InterruptedException e) {
                                               
                                                e.printStackTrace();
                                        }
                                }
                        }
                }.start();
               
                new Thread() {
                        public void run() {
                                while (true) {
                                        try {
                                                p.print2();
                                        } catch (InterruptedException e) {
                                               
                                                e.printStackTrace();
                                        }
                                }
                        }
                }.start();
               
                new Thread() {
                        public void run() {
                                while (true) {
                                        try {
                                                p.print3();
                                        } catch (InterruptedException e) {
                                               
                                                e.printStackTrace();
                                        }
                                }
                        }
                }.start();
        }
}

class Print4 {
        private int flag = 1;
        private ReentrantLock r = new ReentrantLock();
        private Condition c1 = r.newCondition();
        private Condition c2 = r.newCondition();
        private Condition c3 = r.newCondition();
        public void print1() throws InterruptedException {
                r.lock();
                        while (flag != 1) {
                                c1.await();
                        }
                        System.out.println("1");
                        flag = 2;
                        c2.signal();
                r.unlock();
        }
       
        public void print2() throws InterruptedException {
                r.lock();
                        while (flag != 2) {
                                c2.await();
                        }               
                        System.out.println("2");
                        flag = 3;
                        c3.signal();
                r.unlock();
        }
       
        public void print3() throws InterruptedException {
                r.lock();
                        while (flag != 3) {
                                c3.await();
                        }
                        System.out.println("3");
                        flag = 1;
                        c1.signal();
                r.unlock();
        }
}

---

作者: 黑马豹仔    时间: 2016-9-14 08:26
看不懂啊,什么题目都没有

---

作者: java程序猿    时间: 2016-9-14 08:29
感谢楼主分享

---

作者: 370452158    时间: 2016-9-14 11:05
可以哦楼主

---

欢迎光临 黑马程序员技术交流社区 (http://bbs.itheima.com/)

黑马程序员IT技术论坛 X3.2