三个线程-依次打印出1-100;

我不是女神ヾ 2023-10-11 10:17 47阅读 0赞

package com.gxnyt.util;
    
    /**
     * 启用三个线程-依次打印出1-100;
     * 思路：使用wait,notify+信号量(即声明的一个被同步锁-锁住的对象)
     * 有一个小坑： 在最后一个100打印时，不要再让线程进入wait()状态；
     * 因为没有别的线程可以再唤醒它；会一直处在wait()状态；而程序挂起；
     * Created by Zjt_WuLing on 2019/9/22.
     */
    public class MultiThreadDemo {
        static Object lockObj = new Object();
        static volatile int printInt = 1;
    
        //声明一个对象，做为被锁的对象；
        // 由同步锁来对该对象上锁；
        // 在某一线程占有该对象时，判断是否可以打印（满足条件），不能打印则释放该对象（wait方法），同时通知需要该对象的其它线程（notifyAll-唤醒其它线程->进入就绪状态）
        public static void main(String[] args) {
            Thread threadFirst = new Thread(new Runnable() {
                @Override
                public void run() {
                    synchronized (lockObj) {
                        while (printInt <= 100) {
                            if (printInt % 3 == 1) {
                                System.out.println("threadName" + Thread.currentThread().getName() + ";i===" + printInt++);
                            }
                            lockObj.notifyAll();
                            if (printInt == 101) {//这里是个小坑;最后一次不执行wait()方法
                                return;
                            }
                            try {
                                lockObj.wait();
                            } catch (InterruptedException e) {
                                e.printStackTrace();
                            }
                        }
                    }
                }
            });
    
            Thread threadSecond = new Thread(new Runnable() {
                @Override
                public void run() {
                    synchronized (lockObj) {
                        while (printInt <= 100) {
                            if (printInt % 3 == 2) {
                                System.out.println("threadName" + Thread.currentThread().getName() + ";i===" + printInt++);
                            }
                            lockObj.notifyAll();
                            try {
                                lockObj.wait();
                            } catch (InterruptedException e) {
                                e.printStackTrace();
                            }
                        }
                    }
                }
            });
    
            Thread threadThird = new Thread(new Runnable() {
                @Override
                public void run() {
                    synchronized (lockObj) {
                        while (printInt <= 100) {
                            if (printInt % 3 == 0) {
                                System.out.println("threadName" + Thread.currentThread().getName() + ";i===" + printInt++);
                            }
                            lockObj.notifyAll();
                            try {
                                lockObj.wait();
                            } catch (InterruptedException e) {
                                e.printStackTrace();
                            }
                        }
                    }
                }
            });
            threadFirst.start();
            threadSecond.start();
            threadThird.start();
        }
    }

![format_png][]

关于线程的五种状态如上图；

[format_png]: https://imgconvert.csdnimg.cn/aHR0cHM6Ly9pbWFnZXMyMDE3LmNuYmxvZ3MuY29tL2Jsb2cvNDMyNTEzLzIwMTcxMi80MzI1MTMtMjAxNzEyMTQxNjA0Mzg3MTctMTY2MTg0ODA2My5wbmc?x-oss-process=image/format,png