Класс Thread и интерфейс Runnable.

· Thread(ThreadGroup group, Runnable target, String name) -- создает подпроцесс с именем name, принадлежащий группе group и выполняющий метод run() объекта target. Это основной конструктор, все остальные обращаются к нему с тем или иным параметром, равным null;

· Thread() -- создаваемый поток будет выполнять свой метод run();

· Thread(Runnable target);

· Thread(Runnable target, String name);

· Thread(String name);

· Thread(ThreadGroup group, Runnable target);

· Thread(ThreadGroup group, String name).

Имя потока name не имеет никакого значения, оно не используется, виртуальной машиной Java и применяется только для различения потоков в программе.

После создания потока его надо запустить методом start(). Виртуальная машина Java начнет выполнять метод run() этого объекта-потока.

Поток завершит работу после выполнения метода run(). Для уничтожения объекта-потока вслед за этим он должен присвоить значение null.

Выполняющийся поток можно приостановить статическим методом 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. Пример программы «Бегущая строка»