Модераторы: Daevaorn
  

Поиск:

Ответ в темуСоздание новой темы Создание опроса
> барьер в многопоточном приложении 
V
    Опции темы
ksili
Дата 5.5.2009, 13:14 (ссылка) | (нет голосов) Загрузка ... Загрузка ... Быстрая цитата Цитата


Эксперт
****


Профиль
Группа: Завсегдатай
Сообщений: 2069
Регистрация: 3.11.2005
Где: Красноярск

Репутация: 1
Всего: 17
У меня основной поток запускает несколько дочерних и должен стоять пока они все не завершатся. Делаю так:

в основном потоке
Код

volatile long wait1 = 0; // глобальная переменная


        for(i = 0; i < n; i++)    
        {
            InterlockedIncrement(&wait1);
            (HANDLE)_beginthreadex(NULL, 0, _solveProc16, &args[i], 0, NULL);    
        }

    // wait all threads
    while(wait1 > 0)    
        SwitchToThread();



в функции потока:
Код

unsigned  __stdcall _solveProc16(void *pArgs)
{
....

    InterlockedDecrement(&wait1);
    return 16;
}

Я не большой знаток, кажется такой while является спин-блокировкой... 

Нет ли здесь каких-нибудь граблей? Дело в том, что в дебаге и в релизе программа работает по-разному, и также результат различается, если запускать из-под IDE и просто екзешник.


--------------------
Ничто так не развивает аналитическое мышление, как отладка сложной программы без возможности пошагового выполнения (с)
PM MAIL   Вверх
Alek86
Дата 5.5.2009, 13:19 (ссылка) | (нет голосов) Загрузка ... Загрузка ... Быстрая цитата Цитата


Эксперт
***


Профиль
Группа: Завсегдатай
Сообщений: 1299
Регистрация: 30.1.2007
Где: Киев

Репутация: 21
Всего: 25
может лучше заюзать WaitForMultipleObjects?
или в boost.thread где-то были группы потоков


--------------------
user posted image    user posted image
PM MAIL   Вверх
Fazil6
Дата 5.5.2009, 13:26 (ссылка) | (нет голосов) Загрузка ... Загрузка ... Быстрая цитата Цитата


Эксперт
***


Профиль
Группа: Завсегдатай
Сообщений: 1653
Регистрация: 3.5.2006
Где: Минск

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

Код


HANDLE h[5];
for(i = 0; i < 5; i++)    
        {
             h[i] = (HANDLE)_beginthreadex(NULL, 0, _solveProc16, &args[i], 0, NULL);    
        }
    
// wait all threads
    WaitForMultipleObjects(5, h, true, INFINITE);
PM MAIL   Вверх
ksili
Дата 5.5.2009, 13:33 (ссылка) | (нет голосов) Загрузка ... Загрузка ... Быстрая цитата Цитата


Эксперт
****


Профиль
Группа: Завсегдатай
Сообщений: 2069
Регистрация: 3.11.2005
Где: Красноярск

Репутация: 1
Всего: 17
Сейчас попробую переписать на WaitForMultipleObjects, но всё же хотелось разобраться и в минусах приведённого кода т.к. у WaitForMultipleObjects количество ожидаемых объектов довольно ограничено и в какой-нибудь задаче может его и не хватить.


--------------------
Ничто так не развивает аналитическое мышление, как отладка сложной программы без возможности пошагового выполнения (с)
PM MAIL   Вверх
Lazin
Дата 5.5.2009, 13:43 (ссылка) | (нет голосов) Загрузка ... Загрузка ... Быстрая цитата Цитата


Эксперт
****


Профиль
Группа: Завсегдатай
Сообщений: 3820
Регистрация: 11.12.2006
Где: paranoid oil empi re

Репутация: 41
Всего: 154
Цитата(ksili @  5.5.2009,  13:33 Найти цитируемый пост)
Сейчас попробую переписать на WaitForMultipleObjects, но всё же хотелось разобраться и в минусах приведённого кода т.к. у WaitForMultipleObjects количество ожидаемых объектов довольно ограничено и в какой-нибудь задаче может его и не хватить. 

а зачем тебе больше 64х потоков, если их больше, то можно ждать сначала первые 64, потом - следующие 64, итд, можно еще сделать так:

Код

boost::thread_group threads;
for (int i = 0; i < boost::thread::hardware_concurrency(); ++i)
    threads.create(&_solveProc16);

....

threads.join_all();


Это сообщение отредактировал(а) Lazin - 5.5.2009, 13:44


--------------------
C++ is the steampunk of programming languages: modern ideas realized with victorian technology.
PM MAIL Skype GTalk   Вверх
J0ker
Дата 5.5.2009, 16:50 (ссылка) | (нет голосов) Загрузка ... Загрузка ... Быстрая цитата Цитата


Опытный
**


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

Репутация: 4
Всего: 14
Lazin, +1

Цитата(ksili @  5.5.2009,  13:14 Найти цитируемый пост)
Я не большой знаток, кажется такой while является спин-блокировкой... 

не является по причине SwitchToThread
но не кошерно - в таких случаях положено использовать механизмы с ожиданием



--------------------
user posted image
PM MAIL   Вверх
Lazin
Дата 5.5.2009, 17:05 (ссылка) | (голосов:1) Загрузка ... Загрузка ... Быстрая цитата Цитата


Эксперт
****


Профиль
Группа: Завсегдатай
Сообщений: 3820
Регистрация: 11.12.2006
Где: paranoid oil empi re

Репутация: 41
Всего: 154
Цитата(ksili @  5.5.2009,  13:14 Найти цитируемый пост)
    // wait all threads
    while(wait1 > 0)    
        SwitchToThread();

если и использовать этот код, то лучше сделать так:

Код

while( InterlockedCompareExchange(&wait1, 0, 0) != 0 )    
        SwitchToThread();


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

Добавлено через 4 минуты и 48 секунд
но это может произойти только на многопроцессорной машине


--------------------
C++ is the steampunk of programming languages: modern ideas realized with victorian technology.
PM MAIL Skype GTalk   Вверх
J0ker
Дата 5.5.2009, 17:46 (ссылка) | (нет голосов) Загрузка ... Загрузка ... Быстрая цитата Цитата


Опытный
**


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

Репутация: 4
Всего: 14
Цитата(Lazin @  5.5.2009,  17:05 Найти цитируемый пост)
то лучше сделать так:

+1

Цитата(Lazin @  5.5.2009,  17:05 Найти цитируемый пост)
иначе, может возникнуть задержка между завершением последнего потока и продолжением работы программы

Добавлено через 4 минуты и 48 секунд
но это может произойти только на многопроцессорной машине 

почему? из-за кэша процессора?


--------------------
user posted image
PM MAIL   Вверх
MAKCim
Дата 5.5.2009, 17:59 (ссылка) | (нет голосов) Загрузка ... Загрузка ... Быстрая цитата Цитата


Воін дZэна
****


Профиль
Группа: Экс. модератор
Сообщений: 5644
Регистрация: 10.12.2005
Где: Менск, РБ

Репутация: 52
Всего: 207
Цитата(Lazin @  5.5.2009,  17:05 Найти цитируемый пост)
иначе, может возникнуть задержка между завершением последнего потока и продолжением работы программы

декрементация может прозойти после выполнения условия в while но до вызова SwithToThread
это классический race


--------------------
Ах, у елі, ах, у ёлкі, ах, у елі злыя волкі ©
PM MAIL   Вверх
J0ker
Дата 5.5.2009, 18:05 (ссылка) | (нет голосов) Загрузка ... Загрузка ... Быстрая цитата Цитата


Опытный
**


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

Репутация: 4
Всего: 14
Цитата(MAKCim @  5.5.2009,  17:59 Найти цитируемый пост)
декрементация может прозойти после выполнения условия в while но до вызова SwithToThread
это классический race 

при чем тут race???
ну завершится цикл на следующем слайсе
нет тут никакого "классического race"


--------------------
user posted image
PM MAIL   Вверх
MAKCim
Дата 5.5.2009, 18:09 (ссылка) | (нет голосов) Загрузка ... Загрузка ... Быстрая цитата Цитата


Воін дZэна
****


Профиль
Группа: Экс. модератор
Сообщений: 5644
Регистрация: 10.12.2005
Где: Менск, РБ

Репутация: 52
Всего: 207
Цитата(J0ker @  5.5.2009,  18:05 Найти цитируемый пост)
при чем тут race???

под race'ом в _конкретном_ случае я понимаю недетерминированность порядка следования сравнения и декрементации
здесь race является безопасным, т. к кроме
Цитата

ну завершится цикл на следующем слайсе

ничего больше произойти не может


--------------------
Ах, у елі, ах, у ёлкі, ах, у елі злыя волкі ©
PM MAIL   Вверх
J0ker
Дата 5.5.2009, 18:16 (ссылка) | (нет голосов) Загрузка ... Загрузка ... Быстрая цитата Цитата


Опытный
**


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

Репутация: 4
Всего: 14
Цитата(MAKCim @  5.5.2009,  18:09 Найти цитируемый пост)
ничего больше произойти не может

именно поэтому это не race condition



--------------------
user posted image
PM MAIL   Вверх
Lazin
Дата 6.5.2009, 08:02 (ссылка) | (нет голосов) Загрузка ... Загрузка ... Быстрая цитата Цитата


Эксперт
****


Профиль
Группа: Завсегдатай
Сообщений: 3820
Регистрация: 11.12.2006
Где: paranoid oil empi re

Репутация: 41
Всего: 154
Цитата(J0ker @  5.5.2009,  17:46 Найти цитируемый пост)
почему? из-за кэша процессора?

ну да, поток, проверяющий значение в цикле while, может не "увидеть" вовремя изменение
если хочешь работать с переменной атомарно, то нужно работать с ней только через Interlocked*** ф-ии, это касается не только записи, но и чтения


--------------------
C++ is the steampunk of programming languages: modern ideas realized with victorian technology.
PM MAIL Skype GTalk   Вверх
MAKCim
Дата 6.5.2009, 08:55 (ссылка) | (нет голосов) Загрузка ... Загрузка ... Быстрая цитата Цитата


Воін дZэна
****


Профиль
Группа: Экс. модератор
Сообщений: 5644
Регистрация: 10.12.2005
Где: Менск, РБ

Репутация: 52
Всего: 207
Цитата(Lazin @  6.5.2009,  08:02 Найти цитируемый пост)
если хочешь работать с переменной атомарно, то нужно работать с ней только через Interlocked*** ф-ии, это касается не только записи, но и чтения 


Цитата(ksili @  5.5.2009,  13:14 Найти цитируемый пост)
while(wait1 > 0)

здесь чтение атомарно, если 
sizeof(long) = 4 и x86, x86-64
или
sizeof(long) = 8 и x86-64

кроме того, кэш сдесь не причем
если переменная (строка) будет находится более чем в одном L1 кэше, то любое ее изменение приведет инвалидации ее в других кэшах
все зависит от того, что отработало раньше: чтение или декремент/инкремент
и никакие Interlocked функции тут не помогут

в данном случае кэширования переменной в регистре не будет из-за volatile

Цитата(J0ker @  5.5.2009,  18:16 Найти цитируемый пост)
именно поэтому это не race condition

самый настоящий race


--------------------
Ах, у елі, ах, у ёлкі, ах, у елі злыя волкі ©
PM MAIL   Вверх
Lazin
Дата 6.5.2009, 10:27 (ссылка) | (нет голосов) Загрузка ... Загрузка ... Быстрая цитата Цитата


Эксперт
****


Профиль
Группа: Завсегдатай
Сообщений: 3820
Регистрация: 11.12.2006
Где: paranoid oil empi re

Репутация: 41
Всего: 154
Цитата(MAKCim @  6.5.2009,  08:55 Найти цитируемый пост)
кроме того, кэш сдесь не причем
если переменная (строка) будет находится более чем в одном L1 кэше, то любое ее изменение приведет инвалидации ее в других кэшах


Цитата(MAKCim @  6.5.2009,  08:55 Найти цитируемый пост)
в данном случае кэширования переменной в регистре не будет из-за volatile

действительно, был не прав smile 


--------------------
C++ is the steampunk of programming languages: modern ideas realized with victorian technology.
PM MAIL Skype GTalk   Вверх
  
 Ответ в темуСоздание новой темы Создание опроса
Правила форума "С++:Общие вопросы"
Earnest Daevaorn

Добро пожаловать!

  • Черновик стандарта C++ (за октябрь 2005) можно скачать с этого сайта. Прямая ссылка на файл черновика(4.4мб).
  • Черновик стандарта C (за сентябрь 2005) можно скачать с этого сайта. Прямая ссылка на файл черновика (3.4мб).
  • Прежде чем задать вопрос, прочтите это и/или это!
  • Здесь хранится весь мировой запас ссылок на документы, связанные с C++ :)
  • Не брезгуйте пользоваться тегами [code=cpp][/code].
  • Пожалуйста, не просите написать за вас программы в этом разделе - для этого существует "Центр Помощи".
  • C++ FAQ

Если Вам понравилась атмосфера форума, заходите к нам чаще! С уважением, Earnest Daevaorn
 
0 Пользователей читают эту тему (0 Гостей и 0 Скрытых Пользователей)
0 Пользователей:
« Предыдущая тема | C/C++: Общие вопросы | Следующая тема »

Подписаться на тему | Подписка на этот форум | Скачать/Распечатать тему


 




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


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

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