Таймер потока в c

Question

Может ли кто-нибудь помочь мне преобразовать мой код в рабочий код:

#include <pthread.h>
#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>

pthread_mutex_t mutex = PTHREAD_MUTEX_INITIALIZER;

/* call back function - inform the user the time has expired */
void timeout_call_back()
{
    printf("=== your time is up ===\n");
    // doing some other stuff
}

/* Go to sleep for a period of seconds */
static void* start_timer(void *args)
{
    /* function pointer */
    void (*finish_function)();


    int seconds = *((int*) args);
    pthread_mutex_lock(&mutex); // I want to do this action atomically
    printf("thread ID : %ld, go to sleep for %d\n", pthread_self(), seconds);

    finish_function = timeout_call_back;

    // ATOMIC PART
    // This function is called in real time, so I need it
    // to be safe, and it's executed just when the timer is not reached.
    atomic_function_callback();

    // THIS IS MY PROBLEM. I WANT TO WAIT for (seconds) seconds,
    // but I don't want to block other threads.
    sleep(seconds); 

    /* call the cb to inform the user time is out */
    (*finish_function)();
    pthread_mutex_unlock(&mutex);

    pthread_exit(NULL);
}

int main()
{
    pthread_t thread1, thread2, thread3;
    int seconds1 = 300;
    int seconds2 = 600;
    int seconds3 = 900;

    int rc1, rc2, rc3;

    rc1 =  pthread_create(&thread1, NULL, start_timer, (void *) &seconds1);
    if(rc1)
    printf("=== Failed to create thread1\n");
    rc2 =  pthread_create(&thread2, NULL, start_timer, (void *) &seconds2);
    if(rc2)
    printf("=== Failed to create thread2\n");

    rc3 =  pthread_create(&thread3, NULL, start_timer, (void *) &seconds3);
    if(rc3)
    printf("=== Failed to create thread3\n");

    pthread_join(thread1, NULL);
    pthread_join(thread2, NULL);
    pthread_join(thread3, NULL);

    printf("=== End of all threads in ===\n");

    return 0;
}

Когда я запускаю этот код, только один поток может работать за раз (причина мьютекса), но мне нужен этот мьютекс.есть ли альтернатива sleep (), которая позволяет мне использовать неблокирующий таймер?

Это всего лишь пример, мои реальные таймеры очень длинные (8 часов).

Спасибо.

Answer 1

Проверьте условные переменные.https://computing.llnl.gov/tutorials/pthreads/#ConditionVariables

Что бы вы сделали, это установите переменную условия и установите время ожидания для вашего сна.Когда вы вызываете синхронизированное ожидание, мьютекс освобождается для других потоков.Когда условная переменная проснется, вы проверите, истек ли ваш таймер, и уведомите ваш обратный вызов finish_function.

.

Answer 2

Ваш вопрос немного расплывчат, но я думаю, что вы хотите, чтобы все три потока спали одновременно, но используйте мьютекс, чтобы убедиться, что ни один из них не запускает функцию финиша одновременно?

Если это так, то вы хотите использовать мьютекс только для защиты вызова функции finish_function, а не для защиты сна.Тогда каждый поток будет спать в стороне друг от друга, и по мере того, как их время истечет, мьютекс будет гарантировать, что только один поток будет вызывать функцию finish_function за раз.

Answer 3

Выезд pthread_cond_timedwait