WaitForSingleObject и WaitForMultipleObjects, эквивалентный в Linux?

Я перемещаю приложение от окон до Linux. Я сталкиваюсь с проблемой относительно WaitForSingleObject и WaitForMultipleObjects интерфейсы.

В моем приложении я порождаю несколько потоков, где все потоки ожидают событий от родительского процесса или периодически выполнения для каждый t секунды.

Я проверил pthread_cond_timedwait, но мы должны указать абсолютное время для этого.

Как я могу реализовать это в Unix?

27
задан jww 3 August 2019 в 17:55
поделиться

4 ответа

Придерживайтесь pthread_cond_timedwait и используйте clock_gettime. Например:

struct timespec ts;
clock_gettime(CLOCK_REALTIME, &ts);
ts.tv_sec += 10; // ten seconds
while (!some_condition && ret == 0)
    ret = pthread_cond_timedwait(&cond, &mutex, &ts);

Оберните его в функцию, если хотите.


ОБНОВЛЕНИЕ: дополняем ответ на основе наших комментариев.

В POSIX нет единого API для ожидания «всех типов» событий / объектов, как в Windows. У каждого свои функции. Самый простой способ уведомить поток о завершении - использовать атомарные переменные / операции. Например:

Основной поток:

// Declare it globally (argh!) or pass by argument when the thread is created
atomic_t must_terminate = ATOMIC_INIT(0);

// "Signal" termination by changing the initial value
atomic_inc(&must_terminate); 

Вторичный поток:

// While it holds the default value
while (atomic_read(&must_terminate) == 0) {
    // Keep it running...
}
// Do proper cleanup, if needed
// Call pthread_exit() providing the exit status

Другой альтернативой является отправка запроса на отмену с использованием pthread_cancel. Отменяемый поток должен был вызвать pthread_cleanup_push, чтобы зарегистрировать любой необходимый обработчик очистки. Эти обработчики вызываются в обратном порядке, в котором они были зарегистрированы. Никогда не вызывайте pthread_exit из обработчика очистки, потому что это неопределенное поведение. Статус выхода отмененной нити - PTHREAD_CANCELED. Если вы выберете эту альтернативу, я рекомендую вам прочитать в основном о точках отмены и типах.

И последнее, но не менее важное: вызов pthread_join сделает текущий поток блоком до тех пор, пока поток, переданный аргументом, не завершится. В качестве бонуса вы получите статус выхода потока.

12
ответ дан jweyrich 28 November 2019 в 05:46
поделиться

Что бы это ни стоило, мы (NeoSmart Technologies) только что выпустили библиотеку с открытым исходным кодом (лицензированную MIT) под названием pevents , которая реализует события ручного и автоматического сброса WIN32 в POSIX, и включает клоны WaitForSingleObject и WaitForMultipleObjects.

Хотя я лично советую вам использовать парадигмы многопоточности и сигнализации POSIX при кодировании на машинах POSIX, pevents дает вам другой выбор, если вам это нужно.

12
ответ дан Mahmoud Al-Qudsi 28 November 2019 в 05:46
поделиться

Я понимаю, что это старый вопрос сейчас, но для всех, кто сталкивается с ним, этот источник предполагает, что pthread_join () делает то же самое, что и WaitForSingleObject ():

http: / /www.ibm.com/developerworks/linux/library/l-ipc2lin1/index.html

Удачи!

1
ответ дан eskimo9 28 November 2019 в 05:46
поделиться

Для WaitForMultipleObjects с ложным WaitAll попробуйте это:

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

using namespace std;

pthread_cond_t condition;
pthread_mutex_t signalMutex;
pthread_mutex_t eventMutex;
int finishedTask = -1;

void* task(void *data)
{
    int num = *(int*)data;
    // Do some
    sleep(9-num);
    // Task finished
    pthread_mutex_lock(&eventMutex); // lock until the event will be processed by main thread
    pthread_mutex_lock(&signalMutex); // lock condition mutex
    finishedTask = num; // memorize task number
    pthread_cond_signal(&condition);
    pthread_mutex_unlock(&signalMutex); // unlock condtion mutex
}

int main(int argc, char *argv[])
{
    pthread_t thread[10];

    pthread_cond_init(&condition, NULL);
    pthread_mutex_init(&signalMutex, NULL); // First mutex locks signal
    pthread_mutex_init(&eventMutex, NULL); // Second mutex locks event processing

    int numbers[10];

    for (int i = 0; i < 10; i++) {
        numbers[i] = i;
        printf("created %d\n", i); // Creating 10 asynchronous tasks
        pthread_create(&thread[i], NULL, task, &numbers[i]);
    }

    for (int i = 0; i < 10;)
    {
        if (finishedTask >= 0) {
            printf("Task %d finished\n", finishedTask); // handle event
            finishedTask = -1; // reset event variable
            i++;
            pthread_mutex_unlock(&eventMutex); // unlock event mutex after handling
        } else {
            pthread_cond_wait(&condition, &signalMutex); // waiting for event
        }
    }

    return 0;
}
1
ответ дан Sorcerer 28 November 2019 в 05:46
поделиться
Другие вопросы по тегам:

Похожие вопросы: