FindSlide.org - это сайт презентаций, докладов, шаблонов в формате PowerPoint.
Email: Нажмите что бы посмотреть
Многопоточное программирование:
•
•
•
Последовательно выполняющиеся инструкции составляют поток.
Потоки выполняются условно независимо. Взаимодействие потоков друг с другом.
© 2013 NetCracker Technology Corp. Confidential.
2
© 2013 NetCracker Technology Corp. Confidential.
3
4
•
run() – метод, который содержит
действия, которые должны выполнятся в
потоке.
start() – унаследованный метод,
который сообщает виртуальной машине,
что необходимо запустить новый поток
исполнения и начать в нём выполнение
метода run().
•
© 2013 NetCracker Technology Corp. Confidential.
10/29/2010
5
Способ запуска:
MyThread t = new MyThread();
t.start();
Пример класса:
public class MyThread extends Thread {
public void run() {
// некоторое долгое вычисление
long sum = 0;
for (int i=0; i < 1000; i++) {
sum+=i;
}
System.out.println(sum);
}
}
сущности,
выполняющей
•
Интерфейс Runnable
объявляет всего один метод – public void run();
© 2010 NetCracker Technology Corp. Confidential.
10/29/2010
6
Runnable r = new MyRunnable();
Thread t = new Thread(r);
t.start();
public class MyRunnable implements Runnable {
public void run() {
// некоторое долгое вычисление
long sum=0;
for (int i=0; i<1000; i++) {
sum+=i;
}
System.out.println(sum);
}
}
void
void void void
static void sleep (long millis) – приостанавливает выполнение потока как минимум на
millis миллисекунд;
static void yield() – приостанавливает выполнение потока, предоставляя возможность
выполнять другие потоки;
public final void join() – ожидание безусловного завершения потока, для которого
вызывается метод
public final synchronized void join(long millis) – ожидание завершения потока или
истечения заданного числа миллисекунд (в зависимости то того, что произойдёт раньше)
public final synchronized void join(long millis, int nanos) – ожидание
•
•
•
•
завершения
потока или тайм-аута с более точным контролем времени
© 2010 NetCracker Technology Corp. Confidential.
10/29/2010
7
•
•
•
•
•
•
•
© 2010 NetCracker Technology Corp. Confidential.
10/29/2010
8
•
•
•
•
•
•
•
•
•
© 2010 NetCracker Technology Corp. Confidential.
10/29/2010
9
Для работы с приоритетами существуют такие основные методы класса Thread:
getPriority(), setPriority()
а так же объявлены три константы:
MIN_PRIORITY, MAX_PRIORITY, NORM_PRIORITY
© 2010 NetCracker Technology Corp. Confidential.
10/29/2010
10
public class ThreadTest implements Runnable {
// Отдельная
// находится
public final
группа, в которой будут
все потоки ThreadTest
static ThreadGroup GROUP =
new ThreadGroup("Daemon demo");
// Стартовое значение
private int start;
public ThreadTest(int
start = (s % 2 ==
new Thread(GROUP,
}
public void run() {
try {
s) {
0) ? s : s+1;
this, "Thread
try
{
while (true) {
// Получаем
// тестовой
int count =
"+start).start();
набор всех потоков из
группы
ThreadTest.GROUP.activeCount();
if (threads.length < count)
threads = new Thread[count+10];
// Начинаем обратный отсчет
for (int i=start; i>0; i--) {
Thread.sleep(300);
count = ThreadTest.GROUP.enumerate(threads);
//
//
if
По достижению середины
порождаем новый
поток с половинным начальным
(start > 2 && i == start/2)
new ThreadTest(i);
значением
// Распечатываем имя каждого потока
for (int i=0; i
System.out.println();
");
}
}
catch (InterruptedException e) {}
Thread.sleep(300);
}
public static void main(String s[]) {
new ThreadTest(16);
new DaemonDemo();
}
}
}
catch (InterruptedException e) {}
}
}
}
© 2010 NetCracker Technology Corp. Confidential.
10/29/2010
11
volatile поля всегда читаются/записываются из/в основной памяти.
© 2010 NetCracker Technology Corp. Confidential.
10/29/2010
13
10/29/2010
14
•
•
•
Планировщик потоков периодически активизирует потоки, ожидающие снятия блокировки
Наличие блокировки не запрещает всех остальных действий с объектом
•
Блокировка
объекта
снимается
автоматически
при
прекращении
выполнения
синхронизированного метода (исключительная ситуация)
На объект возможно наложить блокировку и вызвать несколько синхронизированных
методов
•
•
Каждый объект имеет счётчик блокировок (lock count)
Поток может наложить блокировку на несколько объектов одновременно
•
•
Блокируется только объект, но не метод.
© 2010 NetCracker Technology Corp. Confidential.
10/29/2010
15
• В Java нет никаких средств распознавания или предотвращения ситуаций deadlock.
• Также нет способа перед вызовом синхронизированного метода узнать, заблокирован уже объект другим потоком.
ли
© 2010 NetCracker Technology Corp. Confidential.
10/29/2010
16
•
•
Метод объекта
объекта
notifyAll()
пробуждает
все
потоки из wait-set группы
•
Любой из этих методов может быть вызван потоком у объекта только
после установления блокировки на этот объект
Потоки, после вызова метода wait() снимают все блокировки.
•
•
После
вызова
метода notify()
или
notifyAll()
потоки
пытаются
восстановить ранее снятые блокировки
© 2010 NetCracker Technology Corp. Confidential.
10/29/2010
17
•
Если поток выполняет методы wait(), sleep, join(), прерывание потока методом
interrupt () приводит:
•
Поток прерывает своё выполнение с выбросом исключения InterruptedException
© 2010 NetCracker Technology Corp. Confidential.
10/29/2010
18
10/29/2010
19
