Technologieaustausch

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

Problemhintergrund:

Der Grund dafür ist, dass ich beim Ausführen verteilter Sperren im Unit-Test 10 Threads erstellt und diese dann gestartet habe. Jeder Thread druckt Inhalte in der Ausführungsmethode, aber die Testergebnisse geben tatsächlich nichts aus. Ich war sehr verwirrt und spekulierte dann, dass der Haupt-Thread die Ausführung des Unter-Threads beendet haben könnte und tatsächlich beendet wurde, das Hinzufügen von thread.join() lieferte das erwartete Ergebnis.

Problemschluss:

Dieses Problem besteht nicht, wenn es in der Hauptmethode geschrieben wird, aber dieses Problem besteht beim Einzeltest.

Problemprozess:

Originalcode:

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

Geänderter Code:

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

Notiz:

Thread.join () ist der aktuelle Thread, dh der Hauptthread kann nicht weiter ausgeführt werden, bis die Ausführung des Thread-Threads abgeschlossen ist.