×
Traktatov.net » Философия Java » Читать онлайн
Страница 353 из 395 Настройки

}

}

public String toStringO {

return Thread.currentThreadO.getNameO + ": " + countDown;

}

}. name); t.startO;

}

}

// Отдельный метод для выполнения кода в потоке: class ThreadMethod {

private int countDown = 5; private Thread t; private String name;

public ThreadMethodCString name) { this.name = name; } public void runTaskO { if(t == null) {

t = new Thread(name) {

public void run() { try {

while(true) {

print(this);

if(--countDown == 0) return; sleep(lO);

}

} catchdnterruptedException e) {

printCsleepO interrupted");

}

}

public String toStringO {

return getNameO + ": " + countDown;

}

}:

t.startO;

}

}

}

public class ThreadVariations {

public static void main(String[] args) { new InnerThreadlCInnerThreadl") ; new InnerThread2("InnerThread2"); new InnerRunnablelCInnerRunnablel");

new InnerRunnable2("InnerRunnable2"); продолжение &

new ThreadMethodC'ThreadMethod") runTaskO,

}

} ///-

InnerThreadl определяет именованный внутренний класс, производный от Thread, и создает экземпляр этого класса в конструкторе. Поступать так стоит в том случае, когда у внутреннего класса есть особые возможности (новые методы), которые могут понадобиться в других методах. Однако в большинстве случаев причина создания потока — использование функциональности класса Thread, поэтому в именованном внутреннем классе особой нужды нет. Inner-Thread2 показывает другое решение. В конструкторе создается безымянный внутренний субкласс Thread, преобразуемый восходящим преобразованием к ссылке на Thread t. Если другим методам класса понадобится обратиться к t, они смогут сделать это через интерфейс Thread, и им не нужно будет знать точный тип объекта.

Третий и четвертый классы примера повторяют первые два, только вместо класса Thread они используют интерфейс Runnable.

Класс ThreadMethod демонстрирует создание потока в методе. Вы вызываете метод, когда программа готова к запуску потока, а метод возвращает управление после запуска потока. Если поток выполняет только вспомогательные операции и не является фундаментальной частью класса, то этот способ, вероятно, удобнее и практичнее запуска потока из конструктора класса.

Присоединение к потоку

Любой поток может вызвать метод join(), чтобы дождаться завершения другого потока перед своим продолжением. Если поток вызывает t.join() для другого потока t, то вызывающий поток приостанавливается до тех пор, пока целевой поток t не завершит свою работу (когда метод t.isAlive() вернет значение false).

Вызвать метод join() можно также и с аргументом, указывающим продолжительность ожидания (в миллисекундах или в миллисекундах с наносекундами). Если целевой поток не закончит работу за означенный период времени, метод join() все равно вернет управление инициатору.

Вызов join() может быть прерван вызовом метода interrupt() для потока-инициатора, поэтому потребуется блок try-catch.

Все эти операции продемонстрированы в следующем примере:

// concurrency/Joining java

// Демонстрация joinO.

import static net mindview util Print *;

class Sleeper extends Thread {

private int duration,

public Sleeper(String name, int sleepTime) { super(name), duration = sleepTime, startO,