Форум программистов [Powered by Invision Power Board]

Версия для печати темы
Нажмите сюда для просмотра этой темы в оригинальном формате

Форум программистов > C/C++: Программирование под Unix/Linux > Таймаут в потоках

Автор: Валерия 27.4.2008, 19:44

Код


#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?

Автор: t_gran 28.4.2008, 03:01

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

Автор: Валерия 28.4.2008, 03:48

Я еще подумала над вариантом создать еще один поток, в нём сделать sleep(n) и в конце printf буффера (буффер накапливается потоками, там идет загрузка с разных мест разных файлов xml) и exit smile

А дальше буду в php всё парсить и разгребать, т.к привичнее, просто в нём потоков нет людских)))

Автор: MAKCim 28.4.2008, 09:51

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

Код


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

Цитата(Валерия @ 27.4.2008, 19:44

)

Код


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;
}