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

Поиск:

Ответ в темуСоздание новой темы Создание опроса
> Параллельное выполнение потоков, Debian pthread.h 
:(
    Опции темы
mephis
Дата 8.5.2012, 17:24 (ссылка) | (нет голосов) Загрузка ... Загрузка ... Быстрая цитата Цитата


Новичок



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

Репутация: нет
Всего: нет
Цитата(boostcoder @ 8.5.2012,  17:15)
Цитата(mephis @  8.5.2012,  17:01 Найти цитируемый пост)
после того, как отработал pthread_create. 

сейчас оно так и есть.

не понимаю, в чем проблема?

да, оно так и есть. проблема в том, что, когда использую number в threadFunction, он уже приходит не со своим значением, а number+1. то есть получается у меня так, что number каким-то образом инкрементируется раньше, чем нужно и в threadFunction он уже попадает инкрементированным. поэтому на первой итерации у меня стартует не 0-й таймер, а 1-й. на последней итерации получаю сегфолт, т.к. number на 1 выше, чем моё количество таймеров.
PM MAIL   Вверх
boostcoder
Дата 8.5.2012, 17:32 (ссылка) | (нет голосов) Загрузка ... Загрузка ... Быстрая цитата Цитата


pattern`щик
****


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

Репутация: 16
Всего: 110
тогда тебе нужно не -
Цитата(mephis @  8.5.2012,  17:01 Найти цитируемый пост)
после того, как отработал pthread_create.

а - тогда когда запустилась функция потока.
и почему number не инкрементировать в функции потока?


--------------------
компилятор онлайн с поддержкой C++11
сборки компиляторов MinGW
PM WWW   Вверх
mephis
Дата 8.5.2012, 17:37 (ссылка) | (нет голосов) Загрузка ... Загрузка ... Быстрая цитата Цитата


Новичок



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

Репутация: нет
Всего: нет
Цитата(boostcoder @ 8.5.2012,  17:32)
тогда тебе нужно не -
Цитата(mephis @  8.5.2012,  17:01 Найти цитируемый пост)
после того, как отработал pthread_create.

а - тогда когда запустилась функция потока.
и почему number не инкрементировать в функции потока?

пробовал раньше, до исправления с барьером, ничего не менялось. приду с работы, попробую сделать так ещё раз. 
PM MAIL   Вверх
boostcoder
Дата 8.5.2012, 17:39 (ссылка) | (нет голосов) Загрузка ... Загрузка ... Быстрая цитата Цитата


pattern`щик
****


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

Репутация: 16
Всего: 110
в функцию потока передай указатель на number. в ней, разыменовываешь его, и инкрементируешь.


--------------------
компилятор онлайн с поддержкой C++11
сборки компиляторов MinGW
PM WWW   Вверх
sergioK1
Дата 8.5.2012, 22:43 (ссылка) | (нет голосов) Загрузка ... Загрузка ... Быстрая цитата Цитата


Опытный
**


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

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

Код

 pthread_create(&myThread[this->number], NULL, threadFunction, this);
        this->number++;


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


boostcoder
барьер тут не поможет,  

с передачай указателя  да ,  cчетчик должен быть внутри threadFunction - это просто логичнее, 
  поговорка  есть на такой случай ,  
"При правильном дизайне программа пишеться сама "

Это сообщение отредактировал(а) sergioK1 - 9.5.2012, 08:07
PM MAIL   Вверх
xvr
Дата 10.5.2012, 14:13 (ссылка) | (нет голосов) Загрузка ... Загрузка ... Быстрая цитата Цитата


Эксперт
****


Профиль
Группа: Комодератор
Сообщений: 7046
Регистрация: 28.8.2007
Где: Дублин, Ирландия

Репутация: 20
Всего: 223
Вынесите number из Deamon вообще, и передавайте его отдельной структурой (вместе с this) на куче:
Код

struct Data {
 int number;
 Deamon* self;
};

bool Deamon::connectDB(char* host, char* name, char* password, char* database){
...
 Data loc_data={0,this};

    while ((row = mysql_fetch_row(this->result)) != NULL){
...
        pthread_create(&myThread[this->number], NULL, threadFunction, new Data(loc_data));
        loc_data.number++;
    }
...
}
void* Deamon::threadFunction(void* arg){
    Data threadDmn = *((Data*)(arg));
    delete ((Data*)(arg));
    threadDmn.self->curTimer.at(threadDmn.number).startTimer();
}

Тогда барьеры не нужны
PM MAIL   Вверх
mephis
Дата 11.5.2012, 11:04 (ссылка) | (нет голосов) Загрузка ... Загрузка ... Быстрая цитата Цитата


Новичок



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

Репутация: нет
Всего: нет
Цитата(xvr @ 10.5.2012,  14:13)
Вынесите number из Deamon вообще, и передавайте его отдельной структурой (вместе с this) на куче:
Код

struct Data {
 int number;
 Deamon* self;
};

bool Deamon::connectDB(char* host, char* name, char* password, char* database){
...
 Data loc_data={0,this};

    while ((row = mysql_fetch_row(this->result)) != NULL){
...
        pthread_create(&myThread[this->number], NULL, threadFunction, new Data(loc_data));
        loc_data.number++;
    }
...
}
void* Deamon::threadFunction(void* arg){
    Data threadDmn = *((Data*)(arg));
    delete ((Data*)(arg));
    threadDmn.self->curTimer.at(threadDmn.number).startTimer();
}

Тогда барьеры не нужны

так и сделал. всё работает.

всем спасибо за помощь.
PM MAIL   Вверх
xvr
Дата 11.5.2012, 11:15 (ссылка) | (нет голосов) Загрузка ... Загрузка ... Быстрая цитата Цитата


Эксперт
****


Профиль
Группа: Комодератор
Сообщений: 7046
Регистрация: 28.8.2007
Где: Дублин, Ирландия

Репутация: 20
Всего: 223
Цитата(mephis @  11.5.2012,  11:04 Найти цитируемый пост)
так и сделал. всё работает.

Кстати, если у вас это не учебная задача, и критично быстродействие при запуске thread'ов, то у этого подхода есть маленький недостаток. На каждое создание thread'а будет вызванна пара new/delete. Этого можно избежать заранее выделив массив из структур Data и передавая в создаваемый thread указатели на элементы этого массива по очереди (только надо внимательно следить за индексом элемента, что бы он не вышел за границы массива и не наложился на все еще используемые элементы)
PM MAIL   Вверх
mephis
Дата 13.5.2012, 13:26 (ссылка) | (нет голосов) Загрузка ... Загрузка ... Быстрая цитата Цитата


Новичок



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

Репутация: нет
Всего: нет
Цитата(xvr @ 11.5.2012,  11:15)
Цитата(mephis @  11.5.2012,  11:04 Найти цитируемый пост)
так и сделал. всё работает.

Кстати, если у вас это не учебная задача, и критично быстродействие при запуске thread'ов, то у этого подхода есть маленький недостаток. На каждое создание thread'а будет вызванна пара new/delete. Этого можно избежать заранее выделив массив из структур Data и передавая в создаваемый thread указатели на элементы этого массива по очереди (только надо внимательно следить за индексом элемента, что бы он не вышел за границы массива и не наложился на все еще используемые элементы)

задача не учебная. и если будут присутствовать 1000 и больше thread-ов, то проблемы быстродействия сразу скажутся. программа должна работать в реальном времени с постоянно меняющимися данными в БД, поэтому каждое промедление будет критично и может привести к сбою. благодарю за замечание, я это обязательно учту.
PM MAIL   Вверх
sergioK1
Дата 13.5.2012, 13:45 (ссылка) | (нет голосов) Загрузка ... Загрузка ... Быстрая цитата Цитата


Опытный
**


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

Репутация: нет
Всего: нет
Цитата(mephis @ 13.5.2012,  12:26)
 если будут присутствовать 1000 и больше thread-ов, то проблемы быстродействия сразу скажутся. программа должна работать в реальном времени с постоянно меняющимися данными в БД, поэтому каждое промедление будет критично и может привести к сбою. благодарю за замечание, я это обязательно учту.

1000 средов  на одной машине ? 
так может подумать о threadPool 
PM MAIL   Вверх
Ответ в темуСоздание новой темы Создание опроса
Правила форума "С/С++: Программирование под Unix/Linux"
xvr
  • Проставьте несколько ключевых слов темы, чтобы её можно было легче найти.
  • Не забывайте пользоваться кнопкой "Код".
  • Вопросы мобильной разработки тут
  • Телепатов на форуме нет! Задавайте чёткий, конкретный и полный вопрос. Указывайте полностью ошибки компилятора и компоновщика.
  • Новое сообщение должно иметь прямое отношение к разделу форума. Флуд, флейм, оффтопик запрещены.
  • Категорически запрещается обсуждение вареза, "кряков", взлома программ и т.д.

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

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


 




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


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

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