Java 멀티스레딩의 기본 사항에 대한 예제 튜토리얼 공유

최근에 꽃커피를 샀어요. 원두는 커피머신에서 나왔는데 꽃은 지난주 양숴 여행 때 사온 계수나무 꽃이에요.

커피 맛은 조금 더 가볍고 계수나무 향이 더 많이 납니다.

요점:

이 글에서는 wait() inform() informAll() 을 공부할 것입니다.

DEMO1: wait() 및 inform()

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() 및 inform() 사용은 다음과 같아야 합니다. in 동기화 잠금을 획득한 후에만 호출할 수 있습니다. 직접 호출하면 state가 동기화 잠금으로 보호되므로 java.lang.IllegalMonitorStateException 오류가 보고됩니다.

wait()는 wait()가 동기화 잠금을 해제한다는 점에서 sleep()과 다릅니다.

wait() 및 inform()은 동기화 잠금을 기반으로 구현되므로 각 객체 에는 자체 동기화 잠금이 있으므로 wait() 및 inform()은 Object의 메서드가 아닌 Object의 메서드입니다. 실.

DEMO2, wait() 및 informAll():

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() 메서드는 다른 스레드에서 여러 번 호출될 수 있습니다. , 다른 스레드가 대기(차단)할 수 있도록 허용합니다. 통지()를 하나씩 수행하거나 통지All()을 호출하여 한 번에 모두 깨울 수 있습니다.

[관련 추천]

1. 자바 멀티스레딩 기본 상세설명

2.자바 스레드 동기화에 대하여

3.

Java 스레드 동기화 및 동기화 방법에 대한 자세한 설명

위 내용은 Java 멀티스레딩의 기본 사항에 대한 예제 튜토리얼 공유의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!