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

Поиск:

Ответ в темуСоздание новой темы Создание опроса
> Таймаут в потоках 
:(
    Опции темы
Валерия
Дата 27.4.2008, 19:44 (ссылка) | (нет голосов) Загрузка ... Загрузка ... Быстрая цитата Цитата


Опытный
**


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

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



Код

#include <stdio.h>
#include <stdlib.h>
#include <errno.h>
#include <netdb.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <pthread.h>
#include <string.h>

char all[10000000];


    void * thread_func(void *arg)    {

        int loc_id = * (int *) arg;
        //делаем какието фичи
                        str_cat(all, что-то);

    }

    int main(int argc, char * argv[]){
        int i;
        pthread_t threads[100];
        for (i=0; i<10; i++){
            pthread_create(&threads[i], NULL, thread_func, &i);
            pthread_join(threads[i], NULL);
        }
        return 0;
    }

Собственно, как сделать что бы на протяжении n секунд, если какаята из функций потока не успела выполниться, или если всё повыполняеться, то что бы скрипт остановился и вывел содержимое all?
PM MAIL   Вверх
t_gran
Дата 28.4.2008, 03:01 (ссылка) | (нет голосов) Загрузка ... Загрузка ... Быстрая цитата Цитата


Опытный
**


Профиль
Группа: Участник
Сообщений: 621
Регистрация: 13.11.2007
Где: г.Усть-Илимск

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



Ставим таймер, а затем либо pthread_cancel (если нужно завершить поток), либо вообще pthread_exit. А в общем, проще всего man pthread, и там ищем что надо. smile


--------------------
Я знаю, что ничего не знаю© Сократ
user posted image
PM MAIL WWW   Вверх
Валерия
Дата 28.4.2008, 03:48 (ссылка) | (нет голосов) Загрузка ... Загрузка ... Быстрая цитата Цитата


Опытный
**


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

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



Я еще подумала над вариантом создать еще один поток, в нём сделать sleep(n) и в конце printf буффера (буффер накапливается потоками, там идет загрузка с разных мест разных файлов xml) и exit smile
А дальше буду в php всё парсить и разгребать, т.к привичнее, просто в нём потоков нет людских)))
PM MAIL   Вверх
MAKCim
Дата 28.4.2008, 09:51 (ссылка) | (нет голосов) Загрузка ... Загрузка ... Быстрая цитата Цитата


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


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

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



Валерия
код-то неправильный
1.
Код

void * thread_func(void *arg)    {
        int loc_id = (int)arg;
        //делаем какието фичи
                        str_cat(all, что-то);
    }
...
pthread_create(&threads[i], NULL, thread_func, (void*)i);

2.
Цитата(Валерия @  27.4.2008,  19:44 Найти цитируемый пост)
Собственно, как сделать что бы на протяжении n секунд, если какаята из функций потока не успела выполниться, или если всё повыполняеться, то что бы скрипт остановился и вывел содержимое all? 

Код

static atomic_t count = ATOMIC_INIT(10);
static pthread_cond_t waiter = PTHREAD_COND_INITIALIZER;
static pthread_mutex_t all_mutex = PTHREAD_MUTEX_INITIALIZER;

void * thread_func(void * arg) {
        int loc_id = (int)arg;
        pthread_setcancelstate(PTHREAD_CANCEL_ENABLE, NULL);
        pthread_setcanceltype(PTHREAD_CANCEL_DEFFERED, NULL);
        //делаем какието фичи
        pthread_mutex_lock(&all_mutex);
                        str_cat(all, что-то);
        pthread_mutex_unlock(&all_mutex);
        if (atomic_dec_and_test(&count))
            pthread_cond_signal(&waiter);
}

int main(int argc, char * argv[]){
        int i;
        pthread_t threads[10];
        pthread_mutex_t mutex = PTHREAD_MUTEX_INITIALIZER;
        struct timespec timespec = {
            .tv_sec = 3,
            .tv_nsec = 0
        };
        pthread_mutex_lock(&mutex);
        for (i=0; i<10; i++)
            pthread_create(&threads[i], NULL, thread_func, (void*)i);
        pthread_cond_timedwait(&waiter, &mutex, &timespec);
        pthread_mutex_unlock(&mutex);
        for (i=0; i<10; i++)
            pthread_cancel(threads[i]);
        while (atomic_read(&count));
        return 0;
}



--------------------
Ах, у елі, ах, у ёлкі, ах, у елі злыя волкі ©

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

Если Вам понравилась атмосфера форума, заходите к нам чаще! С уважением, xvr.

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


 




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


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

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