Главное не ждать потоков даже после использования Thread.join() в Java

Question

Функция join() заставляет функцию main ждать, пока все потоки не завершат выполнение, но main печатает completed до Thread-1 а также Thread-2 завершает выполнение. Я не могу найти ошибку в коде. где ошибка?

class ThreadDemo extends Thread {
    private Thread t;
    private String threadName;

    ThreadDemo(String name) {
        threadName = name;
    }
    public void run() {
        System.out.println("Thread " + threadName + " exiting.");
    }
    public void start() {
        if (t == null) {
            t = new Thread (this, threadName);
            t.start();
        }
    }
}
public class Problem2 {
    public static void main(String[] args) {
        ThreadDemo T1 = new ThreadDemo("Thread-1");
        ThreadDemo T2 = new ThreadDemo("Thread-2");
        T1.start();
        T2.start();
        try {
            T1.join();
            T2.join();
        } catch (InterruptedException e) {
            System.out.println("ERROR!");
        }
        System.out.println("completed");
    }
}

Выход

completed
Thread Thread-2 exiting.
Thread Thread-1 exiting.

Answer 1

Вы присоединяетесь к экземплярам ThreadDemo. Но вы не запускаете эти экземпляры как потоки. Ваш переопределен start Метод создает и запускает другой поток.

Ваш код очень запутанный. Вы используете наследование и делегирование, переопределяете методы и нарушаете их контракт: start() должен начинаться this как поток, а не создавать и запускать другой поток.

Вот как это должно выглядеть:

class ThreadDemo implements Runnable {
    private String threadName;

    ThreadDemo(String name) {
        this.threadName = name;
    }

    @Override
    public void run() {
        System.out.println("Thread " + threadName + " exiting.");
    }

}
public class Problem2 {
    public static void main(String[] args) {
        ThreadDemo runnable1 = new ThreadDemo("Thread-1");
        ThreadDemo runnable2 = new ThreadDemo("Thread-2");

        Thread t1 = new Thread(runnable1);
        Thread t2 = new Thread(runnable2);

        t1.start();
        t2.start();
        try {
            t1.join();
            t2.join();
        } catch (InterruptedException e) {
            System.out.println("ERROR!");
        }
        System.out.println("completed");
    }
}