Модераторы: Snowy, bartram, MetalFan, bems, Poseidon, Riply
  

Поиск:

Ответ в темуСоздание новой темы Создание опроса
> Event, синхронизация 
:(
    Опции темы
verus84
Дата 15.10.2015, 15:45 (ссылка) | (нет голосов) Загрузка ... Загрузка ... Быстрая цитата Цитата


Новичок



Профиль
Группа: Участник
Сообщений: 2
Регистрация: 15.10.2015

Репутация: нет
Всего: нет



Есть несколько потоков которые ожидают Event, но тут есть одна проблема что при вызове  PulseEvent потоки не всегда успевают перейти в ожидание, в этом примере после создания потоков делаем задержку 1500мс и все работает, но как сделать по-нормальному? 
Ни чего кроме как ZwQuerySystemInformation(SYSTEM_PROCESSES_AND_THREADS_INFORMATION) и там уже проверять в каком состоянии поток находится больше в голову не приходит, но этот способ не сказал бы что лучше т.к. еще и в цикле придется проверять и ждать.

Код

program Project1;

{$APPTYPE CONSOLE}

uses
  SysUtils,
  windows;

var
tid: DWORD;
evnt: DWORD;
mut:  DWORD;

procedure Th1(p: PChar); stdcall;
var
dwWaitResult: DWORD;
begin

  while true do
  begin

    dwWaitResult := WaitForSingleObject(evnt, INFINITE);


    if (dwWaitResult = WAIT_OBJECT_0) then
    writeln('th1Signale');



  end;


end;


procedure Th2(p: PChar); stdcall;
var
dwWaitResult: DWORD;
begin

  while true do
  begin
    dwWaitResult := WaitForSingleObject(evnt, INFINITE);

    if (dwWaitResult = WAIT_OBJECT_0) then
    writeln('th2Signale');



  end;


end;


procedure Th3(p: PChar); stdcall;
var
dwWaitResult: DWORD;
begin
  while true do
  begin
    dwWaitResult := WaitForSingleObject(evnt, INFINITE);

    if (dwWaitResult = WAIT_OBJECT_0) then
    writeln('th3Signale');


  end;

end;



begin
evnt := CreateEvent(nil, true, FALSE, nil);

CreateThread(nil, 0, @Th1, nil, 0, tid);
CreateThread(nil, 0, @Th2, nil, 0, tid);
CreateThread(nil, 0, @Th3, nil, 0, tid);


sleep(1500);
PulseEvent(evnt);

readln;
end.

PM MAIL   Вверх
bems
Дата 16.10.2015, 19:22 (ссылка) | (нет голосов) Загрузка ... Загрузка ... Быстрая цитата Цитата


Эксперт
****


Профиль
Группа: Комодератор
Сообщений: 3400
Регистрация: 5.1.2006

Репутация: 21
Всего: 88



а почему не SetEvent? ну и после него дождаться окончания всех потоков.


--------------------
Обижено школьников: 8
PM MAIL   Вверх
Sajtran
Дата 16.10.2015, 19:52 (ссылка) |    (голосов:1) Загрузка ... Загрузка ... Быстрая цитата Цитата


Новичок



Профиль
Группа: Участник
Сообщений: 9
Регистрация: 15.10.2008
Где: Мегион

Репутация: нет
Всего: 2



Цитата
PulseEvent function
   Note  This function is unreliable and should not be used. It exists mainly for backward compatibility. For more information, see Remarks.
   Remarks
   A thread waiting on a synchronization object can be momentarily removed from the wait state by a kernel-mode APC, and then returned to the wait state after the APC is complete. If the call to PulseEvent occurs during the time when the thread has been removed from the wait state, the thread will not be released because PulseEvent releases only those threads that are waiting at the moment it is called. Therefore, PulseEvent is unreliable and should not be used by new applications. Instead, use condition variables.
   
Condition Variables

Этот ответ добавлен с нового Винграда - http://vingrad.com
PM MAIL   Вверх
Alexeis
Дата 16.10.2015, 23:25 (ссылка) | (нет голосов) Загрузка ... Загрузка ... Быстрая цитата Цитата


Амеба
Group Icon


Профиль
Группа: Админ
Сообщений: 11743
Регистрация: 12.10.2005
Где: Зеленоград

Репутация: 16
Всего: 459



Цитата(verus84 @  15.10.2015,  16:45 Найти цитируемый пост)
Есть несколько потоков которые ожидают Event, но тут есть одна проблема что при вызове  PulseEvent потоки не всегда успевают перейти в ожидание, в этом примере после создания потоков делаем задержку 1500мс и все работает, но как сделать по-нормальному? 

  Мое мнение, что задача больше похожа на семафор. Взводим семафор на число потоков и каждый поток гарантированно отработает по разу.


--------------------
Vit вечная память.

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

гениальность идеи состоит в том, что ее невозможно придумать
PM ICQ Skype   Вверх
verus84
Дата 17.10.2015, 12:33 (ссылка) | (нет голосов) Загрузка ... Загрузка ... Быстрая цитата Цитата


Новичок



Профиль
Группа: Участник
Сообщений: 2
Регистрация: 15.10.2015

Репутация: нет
Всего: нет



Семафор не подходит, нужно что бы выполнилось только один раз и опять перешло к ожиданию нового эвента, в моем случае так и происходит и из-за этого приходтся использовать PulseEvent, а не SetEvent .
PM MAIL   Вверх
Alexeis
Дата 17.10.2015, 16:25 (ссылка) | (нет голосов) Загрузка ... Загрузка ... Быстрая цитата Цитата


Амеба
Group Icon


Профиль
Группа: Админ
Сообщений: 11743
Регистрация: 12.10.2005
Где: Зеленоград

Репутация: 16
Всего: 459



Можно 2 семафора поставить. 1 на начало операции. 1 на конец. 
1) Оба семафора по нулям.
2) 1й семафор сигнализируем по числу потоков.
3) ждем окончания работы потоков
4) 2й семафор сигнализируем по числу потоков. 


--------------------
Vit вечная память.

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

гениальность идеи состоит в том, что ее невозможно придумать
PM ICQ Skype   Вверх
  
Ответ в темуСоздание новой темы Создание опроса
Правила форума "Delphi: WinAPI и системное программирование"
Snowybartram
MetalFanbems
PoseidonRrader
Riply

Запрещено:

1. Публиковать ссылки на вскрытые компоненты

2. Обсуждать взлом компонентов и делиться вскрытыми компонентами

  • Литературу по Delphi обсуждаем здесь
  • Действия модераторов можно обсудить здесь
  • С просьбами о написании курсовой, реферата и т.п. обращаться сюда
  • Вопросы по реализации алгоритмов рассматриваются здесь
  • 90% ответов на свои вопросы можно найти в DRKB (Delphi Russian Knowledge Base) - крупнейшем в рунете сборнике материалов по Дельфи
  • 99% ответов по WinAPI можно найти в MSDN Library, оставшиеся 1% здесь

Если Вам понравилась атмосфера форума, заходите к нам чаще! С уважением, Snowy, bartram, MetalFan, bems, Poseidon, Rrader, Riply.

 
1 Пользователей читают эту тему (1 Гостей и 0 Скрытых Пользователей)
0 Пользователей:
« Предыдущая тема | Delphi: WinAPI и системное программирование | Следующая тема »


 




[ Время генерации скрипта: 0.1209 ]   [ Использовано запросов: 21 ]   [ GZIP включён ]


Реклама на сайте     Информационное спонсорство

 
По вопросам размещения рекламы пишите на vladimir(sobaka)vingrad.ru
Отказ от ответственности     Powered by Invision Power Board(R) 1.3 © 2003  IPS, Inc.