| |||
| БЕСПЛАТНАЯ ежедневная online лотерея! Выигрывай каждый день БЕСПЛАТНО! | |||
| |||
Using Event ObjectsWin32-based applications use event objects in a number of situations to notify a waiting thread of the occurrence of an event. For example, overlapped I/O operations on files, named pipes, and communications devices use an event object to signal their completion. For more information about the use of event objects in overlapped I/O operations, see Synchronization and Overlapped Input and Output. In the following example, an application uses event objects to prevent several threads from reading from a shared memory buffer while a master thread is writing to that buffer. First, the master thread uses the CreateEvent function to create a manual-reset event object. The master thread sets the event object to nonsignaled when it is writing to the buffer and then resets the object to signaled when it has finished writing. Then it creates several reader threads and an auto-reset event object for each thread. Each reader thread sets its event object to signaled when it is not reading from the buffer. #define NUMTHREADS 4 HANDLE hGlobalWriteEvent; void CreateEventsAndThreads(void) { HANDLE hReadEvents[NUMTHREADS], hThread; DWORD i, IDThread; // Create a manual-reset event object. The master thread sets // this to nonsignaled when it writes to the shared buffer. hGlobalWriteEvent = CreateEvent( NULL, // no security attributes TRUE, // manual-reset event TRUE, // initial state is signaled "WriteEvent" // object name ); if (hGlobalWriteEvent == NULL) { // error exit } // Create multiple threads and an auto-reset event object // for each thread. Each thread sets its event object to // signaled when it is not reading from the shared buffer. for(i = 1; i <= NUMTHREADS; i++) { // Create the auto-reset event. hReadEvents[i] = CreateEvent( NULL, // no security attributes FALSE, // auto-reset event TRUE, // initial state is signaled NULL); // object not named if (hReadEvents[i] == NULL) { // Error exit. } hThread = CreateThread(NULL, 0, (LPTHREAD_START_ROUTINE) ThreadFunction, &hReadEvents[i], // pass event handle 0, &IDThread); if (hThread == NULL) { // Error exit. } } } Before the master thread writes to the shared buffer, it uses the ResetEvent function to set the state of hGlobalWriteEvent (an application-defined global variable) to nonsignaled. This blocks the reader threads from starting a read operation. The master then uses the WaitForMultipleObjects function to wait for all reader threads to finish any current read operations. When WaitForMultipleObjects returns, the master thread can safely write to the buffer. After it has finished, it sets hGlobalWriteEvent and all the reader-thread events to signaled, enabling the reader threads to resume their read operations. VOID WriteToBuffer(VOID) { DWORD dwWaitResult, i; // Reset hGlobalWriteEvent to nonsignaled, to block readers. if (! ResetEvent(hGlobalWriteEvent) ) { // Error exit. } // Wait for all reading threads to finish reading. dwWaitResult = WaitForMultipleObjects( NUMTHREADS, // number of handles in array hReadEvents, // array of read-event handles TRUE, // wait until all are signaled INFINITE); // indefinite wait switch (dwWaitResult) { // All read-event objects were signaled. case WAIT_OBJECT_0: // Write to the shared buffer. break; // An error occurred. default: printf("Wait error: %d\n", GetLastError()); ExitProcess(0); } // Set hGlobalWriteEvent to signaled. if (! SetEvent(hGlobalWriteEvent) ) { // Error exit. } // Set all read events to signaled. for(i = 1; i <= NUMTHREADS; i++) if (! SetEvent(hReadEvents[i]) ) { // Error exit. } } Before starting a read operation, each reader thread uses WaitForMultipleObjects to wait for the application-defined global variable hGlobalWriteEvent and its own read event to be signaled. When WaitForMultipleObjects returns, the reader thread's auto-reset event has been reset to nonsignaled. This blocks the master thread from writing to the buffer until the reader thread uses the SetEvent function to set the event's state back to signaled. VOID ThreadFunction(LPVOID lpParam) { DWORD dwWaitResult, i; HANDLE hEvents[2]; hEvents[0] = (HANDLE) *lpParam; // thread's read event hEvents[1] = hGlobalWriteEvent; dwWaitResult = WaitForMultipleObjects( 2, // number of handles in array hEvents, // array of event handles TRUE, // wait till all are signaled INFINITE); // indefinite wait switch (dwWaitResult) { // Both event objects were signaled. case WAIT_OBJECT_0: // Read from the shared buffer. break; // An error occurred. default: printf("Wait error: %d\n", GetLastError()); ExitThread(0); } // Set the read event to signaled. if (! SetEvent(hEvents[0]) ) { // Error exit. } } | |||
| Пригласи друзей и счет твоего мобильника всегда будет положительным! | |||
| |||
| Пригласи друзей и счет твоего мобильника всегда будет положительным! | |||
Использование Объектов Случаябазирующиеся приложения Win32 используют объекты случая во множестве ситуаций, чтобы уведомлять ждущая резьба о случае случая. Например, перекрывшее действия В/В на файлы, назвавшие трубы, и устройства связи используют объект случая против сигнала их завершение. Более подробно об использовании объектов случая в перекрытых действиях В/В, смотри Синхронизацию и Перекрывшую Вклад и Выход. В следующем примере, приложение использует объекты случая против предохранять несколько резьбы от чтения из коллективного буфера памяти тогда как основная резьба пишется в этот буфер. Сначала, основная резьба использует функцию CreateEvent, чтобы создавать руководство-восстановившее объект случая. Основная резьба устанавливает объект случая против nonsignaled когда она пишется в буфер затем восстанавливает объект против сигнального когда это завершило сочинение. Затем это создает несколько резьбы читателя и авто-восстановившее объект случая для каждой резьбы. Каждая резьба читателя устанавливает свой объект случая против сигнального когда она не читается из буфера. #define NUMTHREADS 4 ПРООПЕРИРУЙТЕ hGlobalWriteEvent; пустота CreateEventsAndThreads(пустота) { ПРООПЕРИРУЙТЕ hReadEvents[NUMTHREADS], hThread; DWORD Я, IDThread; // Создайте руководство-восстановившее объект случая. Основная резьба устанавливает // это на nonsignaled когда она пишется в коллективный буфер. hGlobalWriteEvent = CreateEvent( НЕДЕЙСТВИТЕЛЬНАЯ, // никакая безопасность не приписывает ИСТИНУ, // руководство-восстановившие ИСТИНУ случая, // начальное состояние сигнализировано "WriteEvent" // ОБЪЕКТНОЕ имя ); если (hGlobalWriteEvent == НЕДЕЙСТВИТЕЛЬНЫЙ) { // выход ошибки } // Создайте многочисленную резьбу и авто-восстановившее объект / случай/ для каждой резьбы. Каждая резьба устанавливает свой объект случая против // сигнализированное когда она не читается из коллективного буфера. для(i = 1; я <= NUMTHREADS; я++) { // Создайтесь авто-восстановившее случай. hReadEvents[i] = CreateEvent( НЕДЕЙСТВИТЕЛЬНЫЕ, // никакие атрибуты безопасности ЛОЖЬ, // авто-восстановившая ИСТИНУ случая, // начальное состояние сигнализировано НЕДЕЙСТВИТЕЛЬНЫМ); // объект не назывался если (hReadEvents[i] == НЕДЕЙСТВИТЕЛЬНЫЙ) { // Выход Ошибки. } hThread = CreateThread(НЕДЕЙСТВИТЕЛЬНЫЙ, 0, (LPTHREAD_START_ROUTINE) ThreadFunction, &hReadEvents[i], // ручка случая прохода 0, &IDThread); если (hThread == НЕДЕЙСТВИТЕЛЬНЫЙ) { // Выход Ошибки. } } } Прежде, чем основная резьба напишется в коллективный буфер, она использует функцию ResetEvent, чтобы устанавливать состояние hGlobalWriteEvent ( определенная прикладная глобальная переменная) на nonsignaled. Это блокирует резьбу читателя чтобы начинать с действия чтения. Мастер затем использует функцию WaitForMultipleObjects, чтобы ждать всю резьбу читателя, чтобы завершать любое течение прочитавшее действия. Когда возврат WaitForMultipleObjects, основная резьба может благополучно написаться в буфер. После того, как это завершилось, это устанавливает hGlobalWriteEvent и всего читателя-резьбы событий на сигнализированное, приспосабливаясь резьбу читателя, чтобы продолжать их читанные действия. ПУСТОТА WriteToBuffer(ПУСТОТА) { DWORD dwWaitResult, Я; // Восстановившее hGlobalWriteEvent на nonsignaled, чтобы блокировать читателей. если (! ResetEvent(hGlobalWriteEvent) ) { // Выход Ошибки. } // Ожидание все чтение заправляется на чтение конца. dwWaitResult = WaitForMultipleObjects( NUMTHREADS, // КОЛИЧЕСТВО ручек в массиве hReadEvents, // массив чтения-случая оперирует ИСТИНУ, // ожидание пока все не будут сигнализированы БЕСКОНЕЧНЫЙ); // неопределенное ожидание ключ (dwWaitResult) { // Все прочитавшее-объекты случая были сигнализированы. случай WAIT_OBJECT_0: // Запись в коллективный буфер. прерывание; // Ошибка происходила. невыполнение: printf(ошибка "Wait: %d\n", GetLastError()); ExitProcess(0); } // Установившее hGlobalWriteEvent на сигнализированное. если (! SetEvent(hGlobalWriteEvent) ) { // Выход Ошибки. } // Установленные все прочитанные события на сигнализировали. для(i = 1; я <= NUMTHREADS; я++) если (! SetEvent(hReadEvents[i]) ) { // выход Ошибки. } } Перед начинать с действия чтения, каждая резьба читателя использует WaitForMultipleObjects, чтобы ждать определенную прикладную глобальную переменную hGlobalWriteEvent и собственный случай чтения, которые нужно сигнализировать. Когда возврат WaitForMultipleObjects, читатель заправлять авто-восстановившее случай восстановлен на nonsignaled. Это блокирует основную резьбу от сочинения до буфера пока резьба читателя не использует функцию SetEvent, чтобы устанавливать состояние случая на сигнализированное. ПУСТОТА ThreadFunction(LPVOID lpParam) { DWORD dwWaitResult, Я; ПРООПЕРИРУЙТЕ hEvents[2]; hEvents[0] = (РУЧКА) *lpParam; // заправлять прочитавшее случай hEvents[1] = hGlobalWriteEvent; dwWaitResult = WaitForMultipleObjects( 2, // КОЛИЧЕСТВО ручек в массиве hEvents, // массив случая оперирует ИСТИНУ, // ожидание до них сигнализировано БЕСКОНЕЧНЫМ); // неопределенное ожидание ключ (dwWaitResult) { // Оба объекта случая были сигнализированы. случай WAIT_OBJECT_0: // Прочитанное из коллективного буфера. прерывание; // Ошибка происходила. невыполнение: printf(ошибка "Wait: %d\n", GetLastError()); ExitThread(0); } // Установленный случай чтения на сигнализированное. если (! SetEvent(hEvents[0]) ) { // Выход Ошибки. } } | |||
| |||
 |
