Partage de technologie

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

Contexte du problème :

La raison en est que lors de l'exécution de verrous distribués, j'ai créé 10 threads dans le test unitaire, puis je les ai démarrés. Chaque thread imprimera le contenu dans la méthode run, mais les résultats du test ne génèrent rien. J'étais très perplexe, puis j'ai spéculé que le thread principal aurait pu terminer l'exécution du sous-thread et se terminer directement, l'ajout de thread.join() a obtenu le résultat attendu.

Conclusion du problème :

Ce problème n'existe pas s'il est écrit dans la méthode principale, mais ce problème existe dans les tests uniques.

Processus du problème :

Code d'origine :

@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 ? "上锁成功" : "上锁失败"));
        }
    }

Code modifié :

@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 ? "上锁成功" : "上锁失败"));
        }
    }

Note:

Thread.join() est le thread actuel, c'est-à-dire que le thread principal ne peut pas continuer à s'exécuter tant que l'exécution du thread n'est pas terminée.