class TwoThreads implements Runnable{
private String msg;
private Thread go;
TwoThreads(String s){
msg = s;
go = new Thread(this);
go.start();
}
public void run(){
Thread th = Thread.currentThread();
while(go == th){
try{
Thread.sleep(100);
}
catch(InterruptedException ie){}
System.out.print(msg + " ");
}
System.out.println("End of thread.");
}
public void stop(){go = null;}
public static void main(String[] args){
TwoThreads thl = new TwoThreads ("PING");
TwoThreads th2 = new TwoThreads ("pong");
try{
Thread.sleep(1000);
}
catch(InterruptedException ie){}
thl.stop(); th2.stop();
System.out.printlnf);
}
}
Возможность создания многопоточных программ заложена в язык Java с самого его создания. В каждом объекте есть три метода wait() и один метод notify(), позволяющие приостановить работу потока с этим объектом, позволить другому потоку поработать с объектом, а затем уведомить (notify) первый поток о возможности продолжения работы. Эти методы определены прямо в классе Object и наследуются всеми классами.
С каждым объектом связано множество потоков, ожидающих доступа к объекту (wait set). Вначале этот "зал ожидания" пуст.
Основной метод wait(long millisec) приостанавливает текущий поток this, работающий с объектом, на millisec миллисекунд и переводит его в "зал ожидания", в множество ожидающих потоков. Обращение к этому методу допускается только в синхронизированном блоке или методе, чтобы быть уверенными в том, что с объектом работает только один поток. По истечении millisec или после того, как объект получит уведомление методом notify(), поток готов возобновить работу. Если аргумент millisec равен 0, то время ожидания не определено и возобновление работы потока возможно только после того, как объект получит уведомление методом notify().
Отличие данного метода от метода sleep() в том, что метод wait() снимает блокировку с объекта. С объектом может работать один из потоков из "зала ожидания", обычно тот, который ждал дольше всех, хотя это не гарантируется спецификацией JLS.
Второй метод wait() эквивалентен wait(0). Третий метод wait (long millisec, int nanosec) уточняет задержку на nanosec наносекунд, если их сумеет отсчитать операционная система.
Метод notify() выводит из "зала ожидания" только один, произвольно выбранный поток. Метод notifyAll() выводит из состояния ожидания все потоки. Эти методы тоже должны выполняться в синхронизированном блоке или методе.
Приложение 6. Пример программы «Бегущая строка»
Приведем пример аплета, реализующего прокручивающуюся строку. В отличие от тега языка Microsoft DHTML marquee, Java программа может быть легко модифицирована в зависимости от требований Web дизайнера. Параметры в этот аплет можно передавать из языка HTML.
// Файл AppletThread.java — Аплет, прокручивающий информационную строку
import java.awt.*;
// Основной класс аплета, реализующий нить процесса
public class AppletThread extends java.applet.Applet implements Runnable{
String s; // прокручивающаяся строка
Thread thread; // ссылка на нить процесса аплета
public void init(){
// Создаем и стартуем нить процесса текущего аплета
thread = new Thread(this);
thread.start();
// Получаем из HTML страницы строку для прокрутки
s = getParameter("Marquee");
}
public void run(){
// Бесконечно прокручиваем полученную строку
for (;;){
char c; // вспомогательная переменная
try{
// Принудительно вызываем метод paint
repaint();
// Ждем 0.3 секунды
Thread.sleep(300);
// Алгоритм для прокрутки строки:
//1. Выбираем первый символ текущей строки
c = s.charAt(0);
//2. Смещаем текущую строку на один символ вперед
s = s.substring(1, s.length());
//3. В конец смещенной строки записываем из буферной переменной первый символ
s += c;
}
catch (InterruptedException e){}
}//конец цикла for (;;)
}//конец run()
public void destroy(){
// При завершении аплета “обнуляем” нить процесса
if (thread != null){thread = null;}
}
public void paint(Graphics g){
// Рисуем полученную строку в графическом контексте аплета
g.drawString(s, 10, 20);
}
}
Создадим соответствующий HTML файл.
<!-- Файл AppletThread.html >
<!-- Аплет, прокручивающий в броузере информационную строку >
<applet code=AppletThread width=100 height=40>
<param name="Marquee" value="Hello, Thread!">
</applet>
Обратите внимание на следующее важное обстоятельство. Мы не можем обратиться прямо к методу paint() для перерисовки окна компонента, потому что выполнение этого метода связано с операционной системой — метод paint() выполняется автоматически при каждом изменении содержимого окна, его перемещении и изменении размеров. Для запроса на перерисовку окна в классе Component есть метод repaint().
Метод repaint() ждет, когда представится возможность перерисовать окно, и потом обращается к методу update(Graphics g). При этом нескольку обращений к repaint() могут быть произведены исполняющей системой Java за один раз.