Просмтор этого файла доступен только зарегистрированным пользователям. Но у нас супер быстрая регистрация: достаточно только электронной почты!

Текст из файла (страница 5)

Выполняющийся поток можно приостановить статическим методом sleep(long ms) на ms миллисекунд. Если вычислительная система может отсчитывать наносекунды, то можно приостановить поток с точностью до наносекунд методом sleep(long ms, int nanosec).

В примере 4 класс TwoThreads реализует интерфейс Runnable. Здесь нельзя использовать методы класса Thread, но зато класс TwoThreads3 может быть расширением другого класса. Например, можно сделать его аплетом, расширив класс Applet или JApplet.

Пример 4. Реализация интерфейса Runnable

class TwoThreads3 implements Runnable{

private String msg;

TwoThreads3(String s){ msg = s; }

public void run(){

for(int i = 0; i < 20; i++){

try{

Thread.sleep(100);

}

catch(InterruptedException ie){}

System.out.print(msg + " ");

}

System.out.println("End of thread.");

}

public static void main (String[] args){

new Thread(new TwoThreads3("PING"), "Thread 1").start ();

new Thread(new TwoThreads3("pong"), "Thread 2").start ();

System.out.println();

}

}

Чаще всего в новом потоке задаются бесконечные действия, выполняющиеся на фоне основных действий: проигрывается музыка, на экране вращается анимированный логотип фирмы, бежит строка. Для реализации такого потока в методе run() задается бесконечный цикл, останавливаемый после того, как объект-поток получит значение null.

В примере 5 показан другой вариант той же самой программы, в которой метод run() выполняется до тех пор, пока текущий объект-поток th совпадает с объектом go, запустившим текущий поток. Для прекращения его выполнения предусмотрен метод stop(), к которому обращается главный поток. Это стандартная конструкция, рекомендуемая документацией J2SDK. Главный поток в данном примере только создает объекты-потоки, ждет одну секунду и останавливает их.

Пример 5. Прекращение работы потоков

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);

}

}

Приложение 5. Согласование работы нескольких потоков

Возможность создания многопоточных программ заложена в язык 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 файл.

Обратите внимание на следующее важное обстоятельство. Мы не можем обратиться прямо к методу paint() для перерисовки окна компонента, потому что выполнение этого метода связано с операционной системой — метод paint() выполняется автоматически при каждом изменении содержимого окна, его перемещении и изменении размеров. Для запроса на перерисовку окна в классе Component есть метод repaint().

Метод repaint() ждет, когда представится возможность перерисовать окно, и потом обращается к методу update(Graphics g). При этом нескольку обращений к repaint() могут быть произведены исполняющей системой Java за один раз.

Характеристики

Список файлов книги