啟動(dòng)兩個(gè)線程, 一個(gè)輸出1,3,5,7,9....99，另一個(gè)輸出2，4，6，8....100，最后在terminal中輸出1,2,3,4,5,6.....100

java 線程實(shí)現(xiàn)

  /**
         * 多線程并發(fā)的時(shí)候需要通過一個(gè)鎖來進(jìn)行wait和notify控制線程的喚醒和等待
         */
        Object lock = new Object();

        /**
         * lambda代碼塊只能操作lambda代碼塊外的final變量,但是有時(shí)候又需要改變這個(gè)變量,
         * 所以通過final數(shù)組來規(guī)避這個(gè)問題。
         */
        final Thread[] threads = new Thread[2];

        /**
         * 當(dāng)兩個(gè)打印線程結(jié)束之后main線程退出
         */
        CountDownLatch countDownLatch = new CountDownLatch(2);

        threads[1] = new Thread(() -> {
            for (int i = 2; i <= 100; i += 2) {
                System.out.println(i);
                /**
                 * wait, notify, notifyAll 等方法需要在同步代碼塊中執(zhí)行以保證并發(fā)安全。
                 */
                synchronized (lock) {
                    try {
                        /**
                         *喚醒thread[0]
                         */
                        lock.notifyAll();
                        if (i != 100) {
                            /**
                             * 本線程進(jìn)入等待狀態(tài)，釋放cpu
                             */
                            lock.wait();
                        }

                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                }
            }
            countDownLatch.countDown();
        });


        threads[0] = new Thread(() -> {
            for (int i = 1; i < 100; i += 2) {
                System.out.println(i);
                synchronized (lock) {
                    try {
                        /**
                         * 當(dāng)i==1時(shí)代表thread[1]尚未開始啟動(dòng)
                         * 當(dāng)i!=1時(shí)喚醒thread[1]
                         * 然后本線程進(jìn)入等待狀態(tài)釋放cpu
                         */
                        if (i == 1) {
                            threads[1].start();
                        } else {
                            lock.notifyAll();
                        }
                        if (i != 99) {
                            lock.wait();
                        }
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                }
            }
            countDownLatch.countDown();
        });

        /**
         * 啟動(dòng)thread[0]
         */
        threads[0].start();

        /**
         * main線程進(jìn)入等待狀態(tài),當(dāng)thread[0]和thread[1]的任務(wù)執(zhí)行完成之后main線程被喚醒
         */
        countDownLatch.await();
        System.out.println("兩個(gè)線程通過notify和wait實(shí)現(xiàn)循環(huán)打印100以內(nèi)的數(shù)");

golang 協(xié)程實(shí)現(xiàn)

協(xié)程是用戶級(jí)別的線程。在java中程序調(diào)度的基本單位是線程，java的線程和操作系統(tǒng)的線程是一一對(duì)應(yīng)的,線程的調(diào)度是由操作系統(tǒng)內(nèi)核完成的。golang中提供了協(xié)程來實(shí)現(xiàn)并發(fā)，多個(gè)協(xié)程運(yùn)行在一個(gè)操作系統(tǒng)的線程上,協(xié)程的調(diào)度由用戶態(tài)代碼來實(shí)現(xiàn)，因而協(xié)程序更加輕量級(jí)。

a := make(chan bool, 1)
    b := make(chan bool)
    Exit := make(chan bool)

    //  <- chan 當(dāng)chan中沒有數(shù)據(jù)時(shí)會(huì)阻塞
    //  a <- true 往chan a 中放入放入一個(gè)值,此時(shí)阻塞的協(xié)程開始執(zhí)行
    //  go func 啟動(dòng)一個(gè)協(xié)程
    go func() {
        for i := 1; i < 100; i += 2 {
            if ok := <-a; ok {
                fmt.Println(i)
                b <- true
            }
        }

    }()

    go func() {
        for i := 2; i <= 100; i += 2 {
            if ok := <-b; ok {
                fmt.Println(i)
                a <- true
            }
        }
        // 循環(huán)打印結(jié)束,主協(xié)程退出
        close(Exit)
    }()

    fmt.Println("end")

    a <- true
    _ := <-Exit