기술나눔

한어Русский языкEnglishFrançaisIndonesianSanskrit日本語DeutschPortuguêsΕλληνικάespañolItalianoSuomalainenLatina

문제 배경:

그 이유는 분산 잠금을 할 때 단위 테스트에서 스레드를 10개 생성한 후 시작했기 때문입니다. 각 스레드는 run 메서드의 내용을 인쇄하지만 테스트 결과는 실제로 아무것도 출력하지 않습니다. 나는 매우 당황했고, 메인 스레드가 하위 스레드 실행을 마치고 바로 종료되었을 수도 있다고 추측했습니다. 물론, thread.join()을 추가하면 예상한 결과를 얻었습니다.

문제 결론:

메인 메소드에서는 이런 문제가 발생하지 않지만, 싱글 테스트에서는 이런 문제가 발생합니다.

문제 프로세스:

원본 코드:

@Test
    public void multipleThreadTest(){
        System.out.println(Thread.currentThread().getName());
        LockThread[] lockThreads = new LockThread[10];
        for (int i=0;i< lockThreads.length;i++){
            lockThreads[i] = new LockThread(new ZkNodeNoneBlockingLock("app"));
        }
        for (LockThread lockThread : lockThreads) {
            lockThread.start();
        }
    }
 
    private static class LockThread extends Thread{
        ZkNodeNoneBlockingLock locker;
        public LockThread(ZkNodeNoneBlockingLock locker){
            this.locker = locker;
        }
        @Override
        public void run() {
            boolean lock = locker.lock();
            System.out.println(this.getName() + (lock ? "上锁成功" : "上锁失败"));
        }
    }

수정된 코드:

@Test
    public void multipleThreadTest(){
        System.out.println(Thread.currentThread().getName());
        LockThread[] lockThreads = new LockThread[10];
        for (int i=0;i< lockThreads.length;i++){
            lockThreads[i] = new LockThread(new ZkNodeNoneBlockingLock("app"));
        }
        for (LockThread lockThread : lockThreads) {
            lockThread.start();
        }
        for (LockThread lockThread : lockThreads){
            try {
                lockThread.join();
            } catch (InterruptedException e) {
                throw new RuntimeException(e);
            }
        }
    }
 
    private static class LockThread extends Thread{
        ZkNodeNoneBlockingLock locker;
        public LockThread(ZkNodeNoneBlockingLock locker){
            this.locker = locker;
        }
        @Override
        public void run() {
            boolean lock = locker.lock();
            System.out.println(this.getName() + (lock ? "上锁成功" : "上锁失败"));
        }
    }

메모:

Thread.join()은 현재 스레드입니다. 즉, 스레드 스레드의 실행이 완료될 때까지 기본 스레드는 계속 실행할 수 없습니다.