Многопоточное программирование на Java Java Advanced. - презентация

1 Многопоточное программирование на Java Java Advanced

2 2 СПбГУ ИТМО Georgiy KorneevJava Advanced / Многопоточное программирование. Средства языка Java Содержание Потоки Блокировки (синхронизация) Мониторы и условия Модель памяти Java Примеры Заключение

3 Потоки Часть 1

4 4Georgiy KorneevJava Advanced / Collections Framework Создание потоков Класс Thread – поток Позволяет создавать потоки и производить операции с ними Интерфейс Runnable – сущность, которая может быть запущена public void run();

5 5Georgiy KorneevJava Advanced / Collections Framework Создание потока (Runnable) Пример кода // Создание потока Thread t = new Thread(new Runnable() { public void run() { System.out.println("Hello"); } }); // Запуск потока t.start();

6 6Georgiy KorneevJava Advanced / Collections Framework Создание потока (Thread) Не рекомендуется использовать Пример кода // Создание потока Thread t = new Thread() { public void run() { System.out.println("Hello"); } }; // Запуск потока t.start();

7 7Georgiy KorneevJava Advanced / Collections Framework Состояния потока Состояние потока возвращается методами int getState() и boolean isAlive() класса Thread getState()isAlive() NEW RUNNABLE+ BLOCKED+ WAITING+ TIMED_WAITING+ TERMINATED

8 8Georgiy KorneevJava Advanced / Collections Framework Свойства потока Основные свойства id – идентификатор потока name – имя потока priority – приоритет daemon – поток-демон Свойства потока не могут изменяться после запуска

9 9Georgiy KorneevJava Advanced / Collections Framework Взаимодействие потоков Создание потока Запуск потока Ожидание окончания потока Прерывание потока

10 10Georgiy KorneevJava Advanced / Collections Framework Ожидание окончания потока Методы класса Thread join() – ожидать до завершения join(long millis) – ожидать до завершения или истечения millis миллисекунд join(long millis, long nanos) – ожидать до завершения или истечения millis миллисекунд и nanos миллисекунд Все методы ожидания кидают InterruptedExcepton

11 11Georgiy KorneevJava Advanced / Collections Framework Прерывание потока Методы класса Thread interrupt() – установить флаг прерывания isInterrupted() – проверить флаг прерывания interrupted() – проверить и сбросить флаг прерывания Методы, которые ожидают в процессе выполнения должны бросать InterruptedException

12 12Georgiy KorneevJava Advanced / Collections Framework Дополнительные методы Приостановка выполнения sleep(time) – приостановить поток на время yield() – позволить выполниться другим потокам Получение текущего потока currentThread()

13 Блокировки (синхронизация) Часть 2

14 14Georgiy KorneevJava Advanced / Collections Framework Общий случай Любой объект может служить блокировкой Снятие блокировки производится автоматически Синтаксис synchronized (o) { // Получение блокировки … } // Снятие блокировки

15 15Georgiy KorneevJava Advanced / Collections Framework Методы экземпляра Метод экземпляра может быть объявлен синхронизованным public synchronized int getValue() { … } Эквивалентно public int getValue() { synchronized (this) { … } }

16 16Georgiy KorneevJava Advanced / Collections Framework Производитель-потребитель (1) Класс данных class Data { private Object data; public void set(Object data) { … } public Object get() { … } }

17 17Georgiy KorneevJava Advanced / Collections Framework Производитель-потребитель (2) Установка значения public void set(Object data) { while (true) { synchronized (this) { if (data == null) { this.data = data; break; }

18 18Georgiy KorneevJava Advanced / Collections Framework Производитель-потребитель (3) Получение значения public Object get() { while (true) { synchronized (this) { if (data != null) { Object d = data; data = null; return d; }

19 Мониторы (условия) Часть 3

20 20Georgiy KorneevJava Advanced / Collections Framework Монитор Любой объект может быть монитором Для взаимодействия с монитором поток должен иметь блокировку на него Методы монитора wait(time?) – ожидание монитора notify() – извещение одного из ждущих потоков notifyAll() – извещение всех ждущих потоков

21 21Georgiy KorneevJava Advanced / Collections Framework Мониторы и блокировки При ожидании монитора блокировка с него снимается При извещении поток не получает управления пока не может получить блокировку обратно Псевдокод monitor.unlock() monitor.await() monitor.lock()

22 22Georgiy KorneevJava Advanced / Collections Framework Производитель-потребитель (2) Установка значения public synchronized void set(Object data) throws InterruptedException { while (data != null) wait(); this.data = data; notify(); }

23 23Georgiy KorneevJava Advanced / Collections Framework Производитель-потребитель (3) Получение значения public synchronized Object get() throws InterruptedException { while (data == null) wait(); Object d = data; data = null; notify(); return d; }

24 Модель памяти Java Часть 3

25 25Georgiy KorneevJava Advanced / Collections Framework Основные свойства Атомарность Видимость Упорядоченность

26 26Georgiy KorneevJava Advanced / Collections Framework Атомарность Атомарная операция выполняется как единое целое Операции над всеми типами кроме long и double являются атомарными

27 27Georgiy KorneevJava Advanced / Collections Framework Пример int a = 0; long b = 0; a = 1; b = -1; Возможные значения a 0 1 Возможные значения b 0 0xffffffff x ffffffff …

28 28Georgiy KorneevJava Advanced / Collections Framework Видимость Изменения произведенные потоком 1 видимы потоком 2 Видимость гарантируется в следующих случаях После изменений поток 1 освободил блокировку, которую захватил поток 2 После изменения поток 1 создал поток 2 Поток 2 дождался окончания потока 1 При неправильной синхронизации изменения могут быть видимы в произвольном порядке

29 29Georgiy KorneevJava Advanced / Collections Framework Пример int a = 0; int b = 0; a = 1; b = 2; Возможные значения пары а, b 0, 0 1, 0 1, 2 0, 2

30 30Georgiy KorneevJava Advanced / Collections Framework Упорядоченность Программы выполняются как если бы они были написаны последовательно С точки зрения других потоков выполнение программы может производиться в произвольном порядке

31 31Georgiy KorneevJava Advanced / Collections Framework Пример int a = 0; a = 1; a = 2; Возможные последовательност и значений а 0, 0 0, 1 0, 2 1, 2 2, 0 2, 1 …

32 32Georgiy KorneevJava Advanced / Collections Framework Volatile-переменные Операции с volatile-переменными всегда атомарны При чтение значения volatile-переменной оно всегда читается из общей памяти При записи значения volatile-переменной оно всегда записывается в общую память Если volatile-ссылка изменилась, то данные доступные по ней могли не измениться

33 33Georgiy KorneevJava Advanced / Collections Framework Пример volatile List l = null; t1() { List l = new ArrayList(); l.add(new Object()); this.l = l; } Object t2() { while (l != null) { return l.get(0); }

34 34Georgiy KorneevJava Advanced / Collections Framework Выводы При отсутствии правильной синхронизации потоки могут увидеть практически что угодно

35 Примеры Часть 4

36 36Georgiy KorneevJava Advanced / Collections Framework Барьер public await(Barrier that) { // 0 synchronized (this) { // 1 this.generation++; // 2 this.notify(); // 3 } // 4 synchronized (that) { // 5 while (this.generation != that.generation) { // 6 that.wait(); // unlock 7, await 8, lock 9 } // 10 } // 11 }

37 37Georgiy KorneevJava Advanced / Collections Framework Диаграмма переходов для барьера

38 38Georgiy KorneevJava Advanced / Collections Framework Гарантированный deadlock public void run() { // 0 synchronized (o1) { // 1 o1.notifyAll(); // 2 synchronized (o2) { // 3 try { o2.wait(); // unlock 4, await 5, lock 6 } catch (InterruptedException e) {} } // 7 } // 8 }

39 39Georgiy KorneevJava Advanced / Collections Framework Диаграмма переходов для deadlock

40 Заключение Часть 6

41 41Georgiy KorneevJava Advanced / Collections Framework Выводы Программы должны быть хорошо синхронизированы Недосинхронизированные программы могут вести себя практически как угодно Пересенхронизированные программы часто страдают deadlockами

42 42Georgiy KorneevJava Advanced / Collections Framework Ссылки JLS. Threads and Locks // n/html/memory.html n/html/memory.html Threads: Doing Two or More Tasks At Once (Java Tutorial) // ial/threads/index.html ial/threads/index.html

43 43 СПбГУ ИТМО Georgiy KorneevJava Advanced / Многопоточное программирование. Средства языка Java Вопросы