Какой аналог у SetEvent в pthread? Опции

[Andrey_Sudnov]

Проблема в том, что в библиотеке PThread нет работы с файловыми дескрипторами. Соответственно, для того чтобы одновременно ожидать завершения какой-либо файловой (или сокетовой) операции или поступления управляющего сигнала от другого потока (например, об отмене операции), приходится использовать неименнованные каналы (pipe и write, вместо SetEvent) и функцию poll (предпочитаю ее, а не select). Перерыл кучу книг, в том числе POSIX стандарт, ничего лучше не придумал. Насколько такое решение накладно по ресурсам? Как организовать такое взаимодействие потоков другим способом?

[RCray]

только у меня так:

Код

void* child_func(void* arg)
{
    struct args_t* args = (args*)arg;
    
    args->size = read(args->fd, args->packet, args->supposed_size);
    args->event.flag = 1;
    pthread_cond_signal(&args->event.event);

    return 0;
}

int parent(struct args_t *args)
{
    pthread_t        child;
    struct timespec    tm;

    if ( pthread_create(&child, NULL, child_func, args) != 0 )
        return ERR_CREATE;

    // задание таймаута
    ...

    while(!args->event.flag)
    {
        res = pthread_cond_timedwait(&args->event.event, &args->event.lock, &tm);
        if (res == ETIMEDOUT)
            return ERR_TIMEOUT;
    }

    args->event.flag = 0;
    return args->errors;
}

[KRS]

Без mutex есть потенциальные проблемы:
если между проверкой и очисткой возникнет еще одно событие вы его потеряете потому что обнулите args->event.flag = 0;

Код

    while(!args->event.flag)
    {
        res = pthread_cond_timedwait(&args->event.event, &args->event.lock, &tm);
        if (res == ETIMEDOUT)
            return ERR_TIMEOUT;
    }

    args->event.flag = 0;
    return args->errors;
}

[RCray]

Без mutex есть потенциальные проблемы:
если между проверкой и очисткой возникнет еще одно событие вы его потеряете потому что обнулите args->event.flag = 0;

да, опять вы правы.
к тому же не лишним будет это

Код

res = pthread_cond_timedwait(&args->event.event, &args->event.lock, &tm);
        if (res == ETIMEDOUT)
        {
            pthread_cancel(созданный ранее поток, от которого ожидается сигнал);
            return ERR_TIMEOUT;
        }