Что такое findslide.org?

FindSlide.org - это сайт презентаций, докладов, шаблонов в формате PowerPoint.


Для правообладателей

Обратная связь

Email: Нажмите что бы посмотреть 

Яндекс.Метрика

Презентация на тему Параллельное программирование WinAPI и OpenMP 7

Содержание

Литература1. И. Одинцов Профессиональное программирование. Системный подход. – «БХВ-Петербург» - 2004. – 610 с.2. Джин Бэкон, Тим Харрис Операционные системы. Параллельные и распределенные системы. – bhv «Питер» - 2004 – 799 с.3. Материалы тренинга Intel для преподавателей,
Параллельное программирование:  WinAPI и OpenMPЛЕКЦИЯ 7Калинина А.П. Литература1. И. Одинцов Профессиональное программирование. Системный подход. – «БХВ-Петербург» - 2004. – Два стиля параллельного программированияСуществуют два стиля параллельного программирования: Модули пассивны, а потоки Необходимость изучения Windows ThreadsЭто «родные» потоки Windows, надстройкой над которыми является стандарт Содержание по WINAPI Функции Win32 Threading API, применяющиеся для Создания потоковУничтожения потоковСинхронизации Win32* «HANDLE» – тип данных для обращения к любому объекту WindowsК каждому Создание потока Win32* CreateThread():  ее предназначениеНа предыдущем слайде показан заголовок функции CreateThread (), которая CreateThread():  первый параметр – «атрибуты безопасности» ThreadAttributesКаждый объект ядра имеет атрибуты CreateThread(): второй параметр –объем стека потока - StacksizeПараметр Stacksize позволяет пользователю определить CreateThread(): третий параметр – имя функции, с выполнения которой поток начнет работу CreateThread(): четвертый параметр - ParameterПотоковой функции требуется только один параметр типа LPVOID CreateThread(): пятый параметр – «режим старта» CreationFlags CreationFlags позволяет определить «режим старта» CreateThread(): шестой параметр – ThreadId ThreadId – параметр «уникальности», который обеспечивает то, Если создать поток не удалось...Если выполнение CreateThread() не завершилось созданием потока, будет Альтернативы CreateThread() – меньше преимуществ...Существуют альтернативные функции создания потоков с помощью Microsoft LPTHREAD_START_ROUTINE StartAddress – третий параметр в CreateThread() – подробнее...CreateThread() ожидает указателя на Чтобы применить явные потоковые функции, необходимо...Выделить участки кода, которые требуется выполнять параллельноИнкапсулировать Уничтожение потоковНеобходимо освободить ресурсы операционной системыПотоковые «HANDLEs» оставляют занятой зарезервированную памятьЕсли потоки Пример: создание потока#include #include DWORD WINAPI helloFunc(LPVOID arg ) { 	printf(“Hello Thread\n”); Что будет...Реализуется одна из двух возможностей:Сообщение “Hello Thread” появится на экранеНа экране Что делать, чтобы потоки выполнили задание...Чтобы избежать создания приложений, которые только «плодят #include #include BOOL threadDone = FALSE ;DWORD WINAPI helloFunc(LPVOID arg ) { Почему не лучший выход – слишком «дорого»...Конечно, в этом случае поток не Как «подождать поток»Ожидание одного объекта (потока)	DWORD WaitForSingleObject(		HANDLE hHandle, 		DWORD dwMilliseconds ); Осуществляет Это уже лучше... Сначала – немного о “handle” -ахОдин поток ждет завершения Это уже лучше...Немного о WaitForSingleObject WaitForSingleObject будет блокировать завершение других потоков, пока Ждать, пока все не закончат....Количество ожидаемых объектов (потоков) не более 64 	DWORD Комментарии к WaitForMultipleObjects nCount - количество ожидаемых «HANDLES» из всего массива HANDLEs. Должно быть nCount Комментарии к WaitFor* функциямПараметром является “HANDLE”В качестве “HANDLE” могут быть рассмотрены различные Объекты ядра (диспетчерские объекты для планирования работы потоков) Windows 2000 [2]поток ядрамьютекс Состояние объектов синхронизации Widows 2000 [2] Задание 1 - напечатать “HelloThreads”Использовать предыдущий пример для вывода сообщения “Hello Thread” Пример ошибкиDWORD WINAPI threadFunc(LPVOID pArg) {  int* p = (int*)pArg; int Временная диаграмма Hello ThreadsЭто один из вариантов – наиболее вероятный: оба потока Условия возникновения гонки данных (Race Conditions)Одновременный доступ к одной переменной для всех Как избежать гонки данныхИспользовать переменные, являющиеся локальными для каждого потокаОписывать переменные в Решение – “Local” StorageDWORD WINAPI threadFunc(LPVOID pArg) {  int myNum = Мьютекс [2]Mutual exclusion – взаимное исключениеСинхронизационный объект, используемый несколькими потоками для обеспечения Мьютекс (Win32* Mutexes)Объект ядра, CreateMutex(…) возвращает ”HANDLE” мьютексаИспользуется «WaitForSingleObject» для «закрытия на Критическая секция (Win32* Critical Section) – действия в “main”«Легковесный мьютекс», но только Критическая секция – действия в потоковой функцииДо «защищаемого кода»	 	EnterCriticalSection(&cs)Блокирует работу других Пример критической секции : генерация случайных чисел – “main”InitializeCriticalSection(&g_cs);for (int i = Критическая секция – в потоковой функции – генерация случайных чиселfor( int i = start_local; i Семафоры [1]Семафор – это защищенная переменная, значение которой можно запрашивать и менять Семафоры - Win32* SemaphoresОбъекты синхронизации, использующие счетчикЭтот счетчик представляет число доступных ресурсовВвел Создание семафора (Win32* Semaphore)HANDLE CreateSemaphore(  LPSECURITY_ATTRIBUTES lpEventAttributes,  LONG lSemInitial, //Начальное Операции ждать – продолжить (Wait and Post)WaitForSingleObject («ожидание одного») – на семафореПока Предназначение семафоровУправлять доступом к структурам данных конечного размераQueues, stacks, dequesСчетчик применяется для «Минусы семафоров» Semaphore«Потеря владельца»Любой поток может освободить семафор раньше, чем другой начнет Бинарный семафор как мьютекс: аналогия с кабинетом врача: свободно - занятоНачало работы, Бинарный семафор как мьютекс: аналогия с кабинетом врача: свободно - занятоПрием больного Пример: бинарный семафор как мьютексГенерация простых чисел:Семафор используется для контроля доступа к Генерация простых чисел – “main”hSem1 = CreateSemaphore(NULL, 1, 1, NULL);// Binary semaphore Генерация простых чисел: потоковая функцияfor( int i = start_local; i Генерация простых чисел: потоковая функция c критической секцией  для последующего сравнения Генерация простых чисел: потоковая функция – распределение работы между потоками (WINAPI) start_number Генерация простых чисел: потоковая функция – распределение работы между потоками (WINAPI, продолжение)for(int Генерация простых чисел: OpenMP– но это не полная аналогия WINAPI! – ЗАТО ЗаданиеИзучить примеры реализации критической секции и бинарного семафора WinAPI на примере программ
Слайды презентации

Слайд 2 Литература
1. И. Одинцов Профессиональное программирование. Системный подход. –

Литература1. И. Одинцов Профессиональное программирование. Системный подход. – «БХВ-Петербург» - 2004.

«БХВ-Петербург» - 2004. – 610 с.

2. Джин Бэкон, Тим Харрис

Операционные системы. Параллельные и распределенные системы. – bhv «Питер» - 2004 – 799 с.

3. Материалы тренинга Intel для преподавателей, апрель 2006

Слайд 3 Два стиля параллельного программирования
Существуют два стиля параллельного программирования:

Два стиля параллельного программированияСуществуют два стиля параллельного программирования: Модули пассивны, а



Модули пассивны, а потоки могут вызывать процедуры для выполнения

кода модулей

Пример: WinAPI

Модули активны и содержат постоянные, заранее определенные процессы

Пример: OpenMP

Слайд 4



Необходимость изучения Windows Threads
Это «родные» потоки Windows, надстройкой

Необходимость изучения Windows ThreadsЭто «родные» потоки Windows, надстройкой над которыми является

над которыми является стандарт OpenMP
В OpenMP используется параллелелизм «вилочного»

типа: в начале параллельной секции (участок кода) потоки одновременно начинают работу, выход из параллельной секции требует завершения работы всех потоков.
Параллелелизм «вилочного» типа – существенное ограничение на выбор задач, производительность вычислений в которых от распараллеливания подобного типа возрастет

Организация более дифференцированного подхода к режиму различных потоков требует другой технологии, например, WinAPI


С другой стороны, методом сравнения OpenMP и WinAPI, можно выделить свойства, общие для технологий многопоточного программирования

Слайд 5 Содержание по WINAPI
Функции Win32 Threading API, применяющиеся

Содержание по WINAPI Функции Win32 Threading API, применяющиеся для Создания потоковУничтожения

для

Создания потоков
Уничтожения потоков

Синхронизации доступа к разделяемым переменным

Простые модели

для программирования координации действий потоков

Слайд 6 Win32* «HANDLE» – тип данных для обращения к

Win32* «HANDLE» – тип данных для обращения к любому объекту WindowsК

любому объекту Windows
К каждому объекту в Windows можно обратиться

с помощью переменной типа «HANDLE»

Указатель на объекты ядра
Потоки, процессы, файлы, события, мьютексы, семафоры, и т.д.

Функция создания объекта возвращает «HANDLE»

Управление объектом можно осуществлять через его «HANDLE»
Напрямую обращаться к объектам нельзя

Слайд 7 Создание потока Win32*

Создание потока Win32*

Слайд 8


CreateThread(): ее предназначение
На предыдущем слайде показан заголовок функции

CreateThread(): ее предназначениеНа предыдущем слайде показан заголовок функции CreateThread (), которая

CreateThread (), которая создает Win32 поток


Этот поток начинает выполнение

функции, описываемой третьим и четвертым параметрами



Данная функция возвращает «HANDLE», который используется для обращения к ее потоку


Слайд 9
CreateThread(): первый параметр – «атрибуты безопасности» ThreadAttributes
Каждый объект

CreateThread(): первый параметр – «атрибуты безопасности» ThreadAttributesКаждый объект ядра имеет атрибуты

ядра имеет атрибуты безопасности

Первый параметр в CreateThread() позволяет программисту

определить атрибуты безопасности для потока

Система защиты объектов Windows определяет совокупности процессов с разрешенным или запрещенным доступом к данным объектам

Значение «NULL» устанавливает значения атрибутов безопасности «по умолчанию»

Слайд 10
CreateThread(): второй параметр –объем стека потока - Stacksize

Параметр

CreateThread(): второй параметр –объем стека потока - StacksizeПараметр Stacksize позволяет пользователю

Stacksize позволяет пользователю определить размер стека потока

Значение ‘0’

позволяет установить объем стека «по умолчанию», равное одному мегабайту


Слайд 11

CreateThread(): третий параметр – имя функции, с выполнения

CreateThread(): третий параметр – имя функции, с выполнения которой поток начнет

которой поток начнет работу - StartAddress

Третий параметр, StartAddress –

это имя функции

В дальнейшем эту функцию будем называть «функция потока», «потоковая функция», «функция для многопоточного выполнения»

С выполнения функции с этим именем поток и начнет свою работу

Это функция с глобальной видимостью, объявляемая как DWORD WINAPI.


Слайд 12
CreateThread(): четвертый параметр - Parameter

Потоковой функции требуется только

CreateThread(): четвертый параметр - ParameterПотоковой функции требуется только один параметр типа

один параметр типа LPVOID («указатель на VOID»). Значение этого

параметра для потока может быть установлено с помощью четвертого параметра.

Если потоковой функции требуется больше, чем одно значение, можно инкапсулировать их в одну структуру, которую и передать в качестве четвертого параметра.

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


Слайд 13
CreateThread(): пятый параметр – «режим старта» CreationFlags
CreationFlags

CreateThread(): пятый параметр – «режим старта» CreationFlags CreationFlags позволяет определить «режим

позволяет определить «режим старта» потока, который создан, но выполнение

которого «приостановлено».

«По умолчанию» ( для этого нужно установить значение параметра, равное ‘0’) работа потока начинается сразу, как только он создается системой.

Слайд 14
CreateThread(): шестой параметр – ThreadId
ThreadId – параметр

CreateThread(): шестой параметр – ThreadId ThreadId – параметр «уникальности», который обеспечивает

«уникальности», который обеспечивает то, что каждое потоковое задание выполняется

своим потоком

может использоваться повторно до тех пор, пока данный поток существует.



Слайд 15

Если создать поток не удалось...
Если выполнение CreateThread() не

Если создать поток не удалось...Если выполнение CreateThread() не завершилось созданием потока,

завершилось созданием потока, будет возвращено «FALSE»

Причина «неудачи» может быть

установлена с помощью вызова GetLastError().

GetLastError()- РЕКОМЕНДУЕТСЯ ВЫПОЛНЯТЬ ВСЕГДА ДЛЯ ЛЮБОГО ОШИБОЧНОГО КОДА

Слайд 16

Альтернативы CreateThread() – меньше преимуществ...
Существуют альтернативные функции создания

Альтернативы CreateThread() – меньше преимуществ...Существуют альтернативные функции создания потоков с помощью

потоков с помощью Microsoft C library.

Это функции “_beginthread”

и “_beginthreadex”.

“_beginthread” лучше не применять, так как

Не включает в себя «атрибуты безопасности»
Не включает в себя «флаги» установки «режима старта»
Не возвращает идентификатор (номер) потока

“_beginthreadex” обладает теми же аргументами, что и CreateThread.

В MSDN – дополнительная информация.

Слайд 17



LPTHREAD_START_ROUTINE StartAddress – третий параметр в CreateThread() –

LPTHREAD_START_ROUTINE StartAddress – третий параметр в CreateThread() – подробнее...CreateThread() ожидает указателя

подробнее...
CreateThread() ожидает указателя на глобальную функцию
Тип возвращаемого этой функцией

значения DWORD
Вызывает стандартные WINAPI
Функция обладает единственным формальным параметром типа LPVOID (void *) – «указатель на void» - четвертый параметр в CreateThread()

DWORD WINAPI MyThreadStart(LPVOID p);

Поток начинает работу с выполнения этой функции

Слайд 18
Чтобы применить явные потоковые функции, необходимо...
Выделить участки кода,

Чтобы применить явные потоковые функции, необходимо...Выделить участки кода, которые требуется выполнять

которые требуется выполнять параллельно
Инкапсулировать выделенный код в потоковую функцию

Если

код, предназначенный для распараллеливания, уже является функцией, то управление выполнением этой функции с помощью входных параметров должно быть переписано таким образом, чтобы координировать работу нескольких потоков.

Добавить вызов CreateThread, чтобы сделать выполнение этой функции многопоточным

Слайд 19

Уничтожение потоков
Необходимо освободить ресурсы операционной системы

Потоковые «HANDLEs» оставляют

Уничтожение потоковНеобходимо освободить ресурсы операционной системыПотоковые «HANDLEs» оставляют занятой зарезервированную памятьЕсли

занятой зарезервированную память

Если потоки закончили работу, необходимо освободить ресурсы

до того, как программа завершит свою работу

Непрерывное создание новых потоков без освобождения ресурсов потоков, которые выполнили свою работу, приведет к «утечке памяти»

Завершение процесса сделает это «за Вас»

BOOL CloseHandle(HANDLE hObject);


Слайд 20 Пример: создание потока
#include
#include

DWORD WINAPI helloFunc(LPVOID arg

Пример: создание потока#include #include DWORD WINAPI helloFunc(LPVOID arg ) { 	printf(“Hello

) {
printf(“Hello Thread\n”);
return 0;
}

main() {
HANDLE hThread

=
CreateThread(NULL, 0, helloFunc,
NULL, 0, NULL );
}

Что будет?


Слайд 21 Что будет...
Реализуется одна из двух возможностей:
Сообщение “Hello Thread”

Что будет...Реализуется одна из двух возможностей:Сообщение “Hello Thread” появится на экранеНа

появится на экране
На экране не появится ничего. Это гораздо

вероятнее, чем первая возможность.
В главном потоке осуществляется управление ресурсами всего процесса (выполняющийся экземпляр программы), а когда главный поток закончит свою работу (а значит, процесс завершится), все потоки будут уничтожены.
Таким образом, если выполнение вызова CreateThread завершится до того, как операционная система создаст потоки и начнет выполнение их заданий, все потоки будут преждевременно уничтожены в связи с завершением процесса

Слайд 22
Что делать, чтобы потоки выполнили задание...
Чтобы избежать создания

Что делать, чтобы потоки выполнили задание...Чтобы избежать создания приложений, которые только

приложений, которые только
«плодят потоки»,
а эти потоки уничтожаются до

того, как они совершат хоть какую-то полезную работу,

необходимо применить какой-нибудь механизм, который не позволит процессу завершится, пока потоки не выполнят свою работу


Слайд 23 #include
#include
BOOL threadDone = FALSE ;

DWORD WINAPI

#include #include BOOL threadDone = FALSE ;DWORD WINAPI helloFunc(LPVOID arg )

helloFunc(LPVOID arg ) {
printf(“Hello Thread\n”);
threadDone = TRUE

;
return 0;
}
main() {
HANDLE hThread = CreateThread(NULL, 0, helloFunc,
NULL, 0, NULL );
while (!threadDone);//”потраченные зря” циклы процессора
}

Может, подождать в цикле, пока каждый поток выполнит свою работу?...

Это не лучший выход!


Слайд 24 Почему не лучший выход – слишком «дорого»...
Конечно, в

Почему не лучший выход – слишком «дорого»...Конечно, в этом случае поток

этом случае поток не будет уничтожен до того, как

выполнит всю свою работу, но...

Пока сообщение не напечатано (а это событие труднопредсказуемое, зависящее от случайных факторов), главный поток находится в состоянии ожидания, постоянно и непрерывно проверяя в цикле, не изменилось ли значение threadDone в результате создания потока.

Однако, если выполнение программы осуществляется на однопроцессорной машине, или машине с гипертредингом, главный поток выполнит тысячи или даже миллионы циклов процессора к тому времени, как будут потоки будут созданы и выполнят свои задания

Итак, вполне очевидно – этот выход из положения не лучший

Слайд 25

Как «подождать поток»
Ожидание одного объекта (потока)
DWORD WaitForSingleObject(
HANDLE hHandle,

Как «подождать поток»Ожидание одного объекта (потока)	DWORD WaitForSingleObject(		HANDLE hHandle, 		DWORD dwMilliseconds );


DWORD dwMilliseconds );
Осуществляет «ожидание потока» (блокирование) до тех

пор, пока

Закончится временной промежуток

Существует поток (handle не станет signaled)
Используется INFINITE («бесконечное») ожидание, пока поток не будет уничтожен

Не требует циклов CPU

Слайд 26
Это уже лучше... Сначала – немного о “handle”

Это уже лучше... Сначала – немного о “handle” -ахОдин поток ждет

-ах
Один поток ждет завершения работы другого потока
Любой «HANDLE» может

быть в одном из двух состояний:
Сигнализирующем (signaled)
Не сигнализирующем (non-signaled)

«HANDLE» потока находится в состоянии «сигнализирует» (signaled), если он завершил работу, и «не сигнализирует» (non-signaled) в противном случае.

Слайд 27
Это уже лучше...Немного о WaitForSingleObject
WaitForSingleObject будет блокировать

Это уже лучше...Немного о WaitForSingleObject WaitForSingleObject будет блокировать завершение других потоков,

завершение других потоков, пока данный поток не закончит свою

работу (handle is signaled);
Второй параметр – это временной предел для ожидания.
Если время ожидания превышено, код становится доступен для выполнения другими потоками, независимо от того, в каком состоянии находится HANDLE.
Чтобы установить условием окончания ожидания завершение работы потока (handle signaled), нужно установить время ожидания «бесконечность» INFINITE (определенное значение константы ).
Любое другое значение временного предела приведет к ошибке. Нужно проверить код ошибки, чтобы установить причину завершения работы функции

WaitForSingleObject может быть применен не только для потока, но и для «события», «мьютекса» и т.д.

Слайд 28
Ждать, пока все не закончат....
Количество ожидаемых объектов (потоков)

Ждать, пока все не закончат....Количество ожидаемых объектов (потоков) не более 64

не более 64

DWORD WaitForMultipleObjects(
DWORD nCount,
CONST HANDLE *lpHandles,

// array
BOOL fWaitAll, // wait for one or all
DWORD dwMilliseconds)

Дождаться всех: fWaitAll==TRUE
Дождаться хоть одного: fWaitAll==FALSE
Завершает работу, если хотя бы один поток свое задание выполнил

Слайд 29
Комментарии к WaitForMultipleObjects
nCount - количество ожидаемых «HANDLES»

Комментарии к WaitForMultipleObjects nCount - количество ожидаемых «HANDLES» из всего массива HANDLEs. Должно быть nCount

из всего массива HANDLEs. Должно быть nCount

nCount элементов начинают свою работу последовательно с адреса lpHandles до lpHandles[nCount-1].
fWaitAll определяет, ждать ли всех nCount объектов или одного из них. Если TRUE, то WaitForMultipleObjects «ждет всех», иначе «ждет одного».

Четвертый параметр такой же, как в WaitForSingleObject.


Слайд 30
Комментарии к WaitFor* функциям
Параметром является “HANDLE”
В качестве “HANDLE”

Комментарии к WaitFor* функциямПараметром является “HANDLE”В качестве “HANDLE” могут быть рассмотрены

могут быть рассмотрены различные типы объектов
Эти объекты могут быть

в двух состояниях
«Сигнализирует» (Signaled) («свободен» - перевод из [2])
«Не сигнализирует» (Non-signaled) («занят» - перевод из [2])

Смысл понятия «signaled» или «non-signaled» зависит от типа объекта

WaitFor* функции заставляют ждать объекты, которые находятся в состоянии “signaled”
Выполнение функции определяется типом объекта, описываемого “HANDLE”
Поток: «сигнализирующий» (signaled) означает «завершивший работу» (здесь: всю, которая была до «WaitFor*»)

Слайд 31 Объекты ядра (диспетчерские объекты для планирования работы потоков)

Объекты ядра (диспетчерские объекты для планирования работы потоков) Windows 2000 [2]поток

Windows 2000 [2]
поток ядра
мьютекс ядра
мутант ядра
событие ядра
пара событий

ядра
семафор ядра
таймер ядра

Слайд 32 Состояние объектов синхронизации Widows 2000 [2]

Состояние объектов синхронизации Widows 2000 [2]

Слайд 33
Задание 1 - напечатать “HelloThreads”
Использовать предыдущий пример для

Задание 1 - напечатать “HelloThreads”Использовать предыдущий пример для вывода сообщения “Hello

вывода сообщения
“Hello Thread” – от каждого потока
Каждому потоку

– сообщить свой номер
Применить цикл for для создания потоков (CreateThread)
Должно быть напечатано
Hello from Thread #0
Hello from Thread #1
Hello from Thread #2
Hello from Thread #3

Слайд 34 Пример ошибки
DWORD WINAPI threadFunc(LPVOID pArg) {
int*

Пример ошибкиDWORD WINAPI threadFunc(LPVOID pArg) { int* p = (int*)pArg; int

p = (int*)pArg;
int myNum = *p;
printf( “Thread

number %d\n”, myNum);
}
. . .
// from main():
for (int i = 0; i < numThreads; i++) {
hThread[i] =
CreateThread(NULL, 0, threadFunc, &i, 0, NULL);
}

Ошибка: значение i будет различным для различных потоков
К тому моменту, когда потоки начнут выполнять задание, i будет другим, чем когда выполнялся вызов CallThread


Слайд 35

Временная диаграмма Hello Threads
Это один из вариантов –

Временная диаграмма Hello ThreadsЭто один из вариантов – наиболее вероятный: оба

наиболее вероятный: оба потока напечатают номер 2. Но, может

быть, первый поток напечатает 1, а второй – 2 – это менее вероятно.
Этот тип ошибки называется «гонки данных» или “data race” – более, чем один поток имеют доступ к одной и той же переменной

Слайд 36 Условия возникновения гонки данных (Race Conditions)
Одновременный доступ к

Условия возникновения гонки данных (Race Conditions)Одновременный доступ к одной переменной для

одной переменной для всех потоков
Конфликты чтение-запись (Read/Write conflict)
Конфликты запись-запись

(Write/Write conflict)

Наиболее частая ошибка
Не всегда легко обнаружить

Слайд 37

Как избежать гонки данных
Использовать переменные, являющиеся локальными для

Как избежать гонки данныхИспользовать переменные, являющиеся локальными для каждого потокаОписывать переменные

каждого потока
Описывать переменные в пределах потоковой функции
Память – резервировать

в стеке потока(Allocate on thread’s stack)
Запоминать для потока (TLS (Thread Local Storage))

Управлять общим доступом к критическим участкам
Доступ «одного» и синхронизация
«Замки», семафоры, события, критические секции, мьютексы...(Lock, semaphore, event, critical section, mutex)

Слайд 38 Решение – “Local” Storage
DWORD WINAPI threadFunc(LPVOID pArg)
{

Решение – “Local” StorageDWORD WINAPI threadFunc(LPVOID pArg) { int myNum =


int myNum = *((int*)pArg);
printf( “Thread number %d\n”,

myNum);
}
. . .

// from main():
for (int i = 0; i < numThreads; i++) {
tNum[i] = i;
hThread[i] =
CreateThread(NULL, 0, threadFunc, &tNum[i],
0, NULL);
}

Каждый поток запоминает то значение i, которое было в момент его создания - tNum[i]



Слайд 39

Мьютекс [2]
Mutual exclusion – взаимное исключение

Синхронизационный объект, используемый

Мьютекс [2]Mutual exclusion – взаимное исключениеСинхронизационный объект, используемый несколькими потоками для

несколькими потоками для обеспечения целостности общего ресурса (как правило,

данных) путем взаимоисключающего доступа
Ресурс, защищенный мьютексом, доступен в настоящий момент времени только одному процессу

Перед тем, как обратиться к такому ресурсу, процесс блокирует его мьютекс, а закончив с ним работать, снимает блокировку

Если мьютекс уже заблокирован другим потоком, то запросивший блокировку поток может либо дождаться освобождения ресурса, либо остаться в активном состоянии и перейти к другим операциям в зависимости от того, какая из процедур была вызвана для блокирования мьютекса

Слайд 40
Мьютекс (Win32* Mutexes)
Объект ядра, CreateMutex(…) возвращает ”HANDLE” мьютекса

Используется

Мьютекс (Win32* Mutexes)Объект ядра, CreateMutex(…) возвращает ”HANDLE” мьютексаИспользуется «WaitForSingleObject» для «закрытия

«WaitForSingleObject» для «закрытия на замок» или «блокирования» мьютекса

Если мьютекс

не заблокирован, “HANDLE” мьютекса в состоянии «сигнализирует» (“Signaled” или «свободен» [2]),

При выполнении функции «WaitForSingleObject» , мьютекс оказывается захваченным одним из потоков и переходит в состояние “non-signaled” («занят» [2])

Блокировка мьютекса снимается с помощью операции ReleaseMutex(…)
CreateMutex(…) //создать новый мьютекс
WaitForSingleObject // «ждать и не подпускать» (wait & lock)
ReleaseMutex(…) // освободить (unlock)

Используется для координации действий множества процессов

Слайд 41

Критическая секция (Win32* Critical Section) – действия в

Критическая секция (Win32* Critical Section) – действия в “main”«Легковесный мьютекс», но

“main”
«Легковесный мьютекс», но только внутри одного процесса

Очень популярная и

часто применяемая конструкция
Новый тип данных
CRITICAL_SECTION cs;
Операторы создания и уничтожения – в главной программе
InitializeCriticalSection(&cs)
DeleteCriticalSection(&cs);

Слайд 42

Критическая секция – действия в потоковой функции
До «защищаемого

Критическая секция – действия в потоковой функцииДо «защищаемого кода»	 	EnterCriticalSection(&cs)Блокирует работу

кода»
EnterCriticalSection(&cs)
Блокирует работу других потоков, если уже есть поток

в критической секции
Разрешает работу «кому-нибудь», если «никого» в критической секции нет
«После» защищаемого кода
LeaveCriticalSection(&cs)




Слайд 43 Пример критической секции : генерация случайных чисел –

Пример критической секции : генерация случайных чисел – “main”InitializeCriticalSection(&g_cs);for (int i

“main”
InitializeCriticalSection(&g_cs);
for (int i = 0; i < numThreads; i++)


{
tNum[i] = i;
hThread[i] =
CreateThread(NULL, 0, threadFunc, &tNum[i], 0, NULL);
}
WaitForMultipleObjects(numThreads, hThread, TRUE, INFINITE);
DeleteCriticalSection(&g_cs);

Слайд 44 Критическая секция – в потоковой функции – генерация

Критическая секция – в потоковой функции – генерация случайных чиселfor( int i = start_local; i

случайных чисел
for( int i = start_local; i

i+=2 )
{
if( TestForPrime(i) )
{
EnterCriticalSection(&g_cs);
globalPrimes[gPrimesFound++] = i; LeaveCriticalSection(&g_cs);
}
}

Слайд 45 Семафоры [1]
Семафор – это защищенная переменная, значение которой

Семафоры [1]Семафор – это защищенная переменная, значение которой можно запрашивать и

можно запрашивать и менять только при помощи специальных операций

P и V и при инициализации.
Концепция семафоров была предложена Дейкстрой в начале 60гг 20 века. Применяют три основные типа семафоров:

Двоичные (бинарные) семафоры, принимающие только два значения {0,1}

Считающие семафоры. Их значения – целые неотрицательные числа

Общие семафоры. Принимают все множество целых чисел.

Слайд 46

Семафоры - Win32* Semaphores
Объекты синхронизации, использующие счетчик
Этот счетчик

Семафоры - Win32* SemaphoresОбъекты синхронизации, использующие счетчикЭтот счетчик представляет число доступных

представляет число доступных ресурсов
Ввел и сформулировал Edsger Dijkstra (1968)

Две

операции для семафора

Ждать [P(s)]:
Поток ждет, пока s > 0, при этом s уменьшается s = s - 1
Одному продолжить [V(s)]: s = s + 1

Семафор «свободен» (signaled) (объекты синхронизации Windows 2000, [2]), когда «показания счетчика» доходят до нуля

Семафор “is in signaled state” («свободен», по переводу [2]), если s>0 ([3], Win32*)

Слайд 47
Создание семафора (Win32* Semaphore)
HANDLE CreateSemaphore(
LPSECURITY_ATTRIBUTES lpEventAttributes,

Создание семафора (Win32* Semaphore)HANDLE CreateSemaphore( LPSECURITY_ATTRIBUTES lpEventAttributes, LONG lSemInitial, //Начальное значение

LONG lSemInitial, //Начальное значение счетчика
LONG lSemMax,

//Максимальное значение счетчика
LPCSTR lpSemName); //

Значение lSemMax должно быть больше или равно 1
Значение lSemInitial должно быть
Больше или равно 0,
Меньше или равно lSemMax, и
Не может выйти за границы диапазона

Слайд 48

Операции ждать – продолжить (Wait and Post)
WaitForSingleObject («ожидание

Операции ждать – продолжить (Wait and Post)WaitForSingleObject («ожидание одного») – на

одного») – на семафоре
Пока не будет == 0, поток

ждет
Уменьшает счетчик на 1, пока он положителен

Увеличение переменной семафора – операция «продолжить» (Post operation)
BOOL ReleaseSemaphore(
HANDLE hSemaphore,
LONG cReleaseCount,
LPLONG lpPreviousCount );

Увеличивает переменную счетчика посредством cReleaseCount
возвращает предыдущее значение через lpPreviousCount

Слайд 49


Предназначение семафоров
Управлять доступом к структурам данных конечного размера
Queues,

Предназначение семафоровУправлять доступом к структурам данных конечного размераQueues, stacks, dequesСчетчик применяется

stacks, deques
Счетчик применяется для нумерации доступных элементов
Управлять доступом к

конечному числу ресурсов
File descriptors, tape drives…
Контролировать число активных потоков в области
Бинарный семафор [0,1] может работать как мьютекс

Слайд 50 «Минусы семафоров» Semaphore
«Потеря владельца»
Любой поток может освободить семафор

«Минусы семафоров» Semaphore«Потеря владельца»Любой поток может освободить семафор раньше, чем другой

раньше, чем другой начнет его «ждать»
Хорошая практика – избегать

семафоров
No concept of abandoned semaphore
If thread terminates before post, semaphore increment may be lost
Зависание

Слайд 51

Бинарный семафор как мьютекс: аналогия с кабинетом врача:

Бинарный семафор как мьютекс: аналогия с кабинетом врача: свободно - занятоНачало

свободно - занято
Начало работы, никого нет, кабинет свободен,
горит

зеленая лампочка
Бинарный семафор инициализируется «1»:
hSem1 = CreateSemaphore(NULL, 1, 1, NULL);
Когда в кабинет заходит больной (один из потоков устанавливает “0” и начинает выполнять защищенный код), загорается красная лампочка, больной обслуживается, очередь ждет за дверью
Значение семафора устанавливается в «0»,
WaitForSingleObject(hSem1, INFINITE);



Сценарий:
Врач может принять только одного больного (один поток может выполнять защищенный код). Очередь больных ждет за дверью.


Слайд 52

Бинарный семафор как мьютекс: аналогия с кабинетом врача:

Бинарный семафор как мьютекс: аналогия с кабинетом врача: свободно - занятоПрием

свободно - занято
Прием больного завершен (поток выполнил защищенный код,

установил “1”), он вышел из кабинета, врач может принять следующего больного, загорелась зеленая лампочка
- выполняется
ReleaseSemaphore(hSem1, 1, NULL);
значение семафора снова устанавливается в «1»

В кабинет заходит больной (следующий поток установил “0” и приступил к выполнению защищенного кода), загорается красная лампочка, новый больной обслуживается, очередь ждет за дверью
Значение семафора устанавливается в «0»,
WaitForSingleObject(hSem1, INFINITE);



«Продолжение приема у врача» - «семафор» регулирует прием у врача (выполнение потоками защищенного кода)


Слайд 53 Пример: бинарный семафор как мьютекс
Генерация простых чисел:

Семафор используется

Пример: бинарный семафор как мьютексГенерация простых чисел:Семафор используется для контроля доступа

для контроля доступа к записи простых чисел в общую

переменную – вместо критической секции

Слайд 54 Генерация простых чисел – “main”
hSem1 = CreateSemaphore(NULL, 1,

Генерация простых чисел – “main”hSem1 = CreateSemaphore(NULL, 1, 1, NULL);// Binary

1, NULL);// Binary semaphore
for (int i = 0;

i < numThreads; i++)
{
tNum[i] = i;
hThread[i] = CreateThread(NULL, 0, threadFunc,
&tNum[i], 0, NULL);
}
WaitForMultipleObjects(numThreads, hThread,
TRUE, INFINITE);

HANDLE hSem1;


Слайд 55 Генерация простых чисел: потоковая функция
for( int i =

Генерация простых чисел: потоковая функцияfor( int i = start_local; i

start_local; i

{
WaitForSingleObject(hSem1, INFINITE); globalPrimes[gPrimesFound++] = i;
ReleaseSemaphore(hSem1, 1, NULL);
}
}

Слайд 56
Генерация простых чисел: потоковая функция c критической секцией

Генерация простых чисел: потоковая функция c критической секцией для последующего сравнения

для последующего сравнения с OPenMP – (распределение работы между

потоками то же, что и «для семафора»)

for( int i = start_local; i <= finish_local; i+=2 )
{
if( TestForPrime(i) )
{
EnterCriticalSection(&g_cs);
globalPrimes[gPrimesFound++] = i; LeaveCriticalSection(&g_cs);
}
}


Слайд 57 Генерация простых чисел: потоковая функция – распределение работы

Генерация простых чисел: потоковая функция – распределение работы между потоками (WINAPI)

между потоками (WINAPI)
start_number = 3;
int kvant =

8;
finish_number = 200000;
int start_local, finish_local;
start_local = start_number + myNum*kvant;
int i_kvant = (finish_number - start_number)/ numThreads;
int one = kvant*numThreads;
int j_limit = 1 + (finish_number - start_number)/one;


Слайд 58 Генерация простых чисел: потоковая функция – распределение работы

Генерация простых чисел: потоковая функция – распределение работы между потоками (WINAPI,

между потоками (WINAPI, продолжение)
for(int j=1; j

start_local + kvant - 1;
if (finish_local>finish_number)
finish_local = finish_number ;
if(start_local <= finish_number)
for( int i = start_local; i <= finish_local; i+=2 )
{...}
}


Слайд 59 Генерация простых чисел: OpenMP– но это не полная

Генерация простых чисел: OpenMP– но это не полная аналогия WINAPI! –

аналогия WINAPI! – ЗАТО МЕНЬШЕ КОДА!
#pragma omp parallel for

schedule(static, 8)
{
for( int i = start; i <= end; i += 2 ){
if( TestForPrime(i) )
#pragma omp critical
globalPrimes[gPrimesFound++] = i; }
}

И задачу создания потоков (главная программа WinAPI), и распределение заданий для потоков (потоковые функции) выполняет одна прагма
#pragma omp parallel for schedule(static, 8)


  • Имя файла: parallelnoe-programmirovanie-winapi-i-openmp-7.pptx
  • Количество просмотров: 132
  • Количество скачиваний: 0