Java マルチスレッドの基本に関するサンプル チュートリアルを共有する

最近フラワーコーヒーを購入しました。豆はコーヒーマシンから出てきたもので、花は先週陽朔への旅行中に買ったキンモクセイの花でした。

コーヒーの味は少し軽めで、キンモクセイの香りが多めです。

本題に入りましょう:

この記事では、 wait() Notice() NoticeAll() を学習しましょう。

DEMO1: wait() と Notice()

public class Test {

    static class ThreadOne extends Thread {

        private Callback mCallback;

        @Override
        public void run() {
            work();
            if (mCallback != null) {
                mCallback.onResult(false);
            }
        }

        // 耗时 3s
        private void work() {
            System.out.println(" 正在查询数据库 1");
            long startTime = System.currentTimeMillis();
            while (true) {
                if (System.currentTimeMillis() - startTime < 3000) {
                    continue;
                }
                break;
            }
        }

        public void setCallback(Callback callback) {
            mCallback = callback;
        }

        public interface Callback {
            void onResult(boolean result);
        }
    }

    static class ThreadTest extends Thread {

        private Object mLock = new Object();

        private ThreadOne mThreadOne;

        @Override
        public void run() {
            workOne();
            System.out.println(" 根据结果继续做其他事情 ");
        }

        private void workOne() {
            mThreadOne = new ThreadOne();
            mThreadOne.setCallback(new ThreadOne.Callback() {
                @Override
                public void onResult(boolean result) {
                    System.out.println(" 查询数据库 1 结束，:" + (result ? " 有数据 " : " 无数据 "));
                    synchronized (mLock) {
                        mLock.notify();
                        System.out.println("--ThreadTest 结束等待 --");
                    }
                }
            });
            mThreadOne.start();
            try {
                synchronized (mLock) {
                    System.out.println("--ThreadTest 进入等待 --");
                    mLock.wait();
                }
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }

    public static void main(String[] var0) {
        ThreadTest threadTest = new ThreadTest();
        threadTest.start();
    }
}

DEMO1 の出力:

--ThreadTest 进入等待--
正在查询数据库 1
查询数据库 1 结束，: 无数据
--ThreadTest 结束等待--
根据结果继续做其他事情

注:

wait() と Notify() を使用する場合は、同期ロックを取得した後に呼び出す必要があります。直接呼び出すと、java.lang が実行されます。 状態が同期ロックによって保護されているため、.IllegalMonitorStateExceptionが報告されるのは間違っています。

wait() は、wait() が同期ロックを解放するという点で sleep() とは異なります。

wait() と Notify() は同期ロックに基づいて実装されているため、各 object は独自の同期ロックを持っているため、wait() と Notify() は Thread ではなく Object のメソッドです。

DEMO2、wait() および NoticeAll():

public class Test {

    private static Object mLock = new Object();

    static class MyThread extends Thread {

        String mName;
        Callback mCallback;

        public MyThread(String name){
            mName = name;
        }

        @Override
        public void run() {
            work();
            if (mCallback != null) {
                mCallback.onResult(false);
            }
        }

        // 耗时 3s
        private void work() {
            System.out.println(mName + " 等待 ");
            try {
                synchronized (mLock) {
                    mLock.wait();
                }
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }

        public void setCallback(Callback callback) {
            mCallback = callback;
        }

        public interface Callback {
            void onResult(boolean result);
        }
    }

    static class ThreadTest extends Thread {



        @Override
        public void run() {
            work("db1");
            work("db2");
            work("db3");

            try {
                sleep(2000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }

            synchronized (mLock) {
                System.out.println(" 唤醒全部 ");
                mLock.notifyAll();
            }
        }

        private void work(String name) {
            final MyThread myThread = new MyThread(name);
            myThread.setCallback(new MyThread.Callback() {
                @Override
                public void onResult(boolean result) {
                    System.out.println(myThread.mName + " 回来了 ");
                }
            });
            myThread.start();
        }
    }

    public static void main(String[] var0) {
        ThreadTest threadTest = new ThreadTest();
        threadTest.start();
    }
}

DEMO2 出力:

db1 等待
db3 等待
db2 等待
唤醒全部
db3 回来了
db1 回来了
db2 回来了

同じオブジェクトの wait() メソッドを異なるスレッドで複数回呼び出すことができ、異なるスレッドを待機 (ブロック) させることができます。 1つずつnotify()を実行することも、notifyAll()を呼び出してすべてを一度に起動することもできます。

【関連する推奨事項】

1. Java マルチスレッドの基本の詳細な説明

2. Java スレッドの同期について

3. Java スレッドの同期と同期方法の詳細な説明

以上がJava マルチスレッドの基本に関するサンプル チュートリアルを共有するの詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。