Teknologian jakaminen

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

Ongelman tausta:

Syynä on se, että tehdessäni hajautettuja lukkoja loin yksikkötestissä 10 säiettä ja aloitin ne. Jokainen säie tulostaa sisällön ajomenetelmällä, mutta testitulokset eivät itse asiassa tulosta mitään. Olin hyvin ymmälläni, ja sitten arvelin, että pääsäie saattoi suorittaa alasäikeen ja päättynyt suoraan. Viesti.join()-tiedoston lisääminen tuotti odotetun tuloksen.

Ongelman johtopäätös:

Tätä ongelmaa ei ole, jos se on kirjoitettu päämenetelmässä, mutta tämä ongelma esiintyy yksittäisessä testauksessa.

Ongelmaprosessi:

Alkuperäinen koodi:

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

Muokattu koodi:

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

Huomautus:

Thread.join() on nykyinen säie, eli pääsäie ei voi jatkaa suoritusta ennen kuin säikeen suoritus on valmis.