Неблокирующий pthread_join

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

Ответ действительно зависит от того, почему вы хотите это сделать. Например, если вы просто хотите очистить мертвые потоки, вероятно, проще всего иметь поток «очистителя мертвых потоков», который зацикливается и соединяется.

Я не уверен, что именно вы имеете в виду, но предполагаю, что вам действительно нужен механизм ожидания и уведомления.

Вкратце, вот как это работает: вы ждете выполнения условия с таймаутом. Ваше ожидание закончится, если:

• Истекло время ожидания, или
• Если условие выполнено.

Вы можете сделать это в цикле и добавить больше интеллекта в вашу логику. Лучший ресурс, который я нашел для этого, связанный с Pthreads, - это этот учебник: Программирование потоков POSIX (https://computing.llnl.gov/tutorials/pthreads/).

Я также очень удивлен, увидев, что в Pthreads нет API для синхронизированного соединения.

Нет pthread_join с синхронизацией, но если вы ждете, что другой поток заблокирован по условиям, вы можете использовать pthread_cond_timed_wait с синхронизацией вместо pthread_cond_wait.

Если вы разрабатываете для QNX, вы можете использовать функцию pthread_timedjoin ().

В противном случае вы можете создать отдельный поток, который будет выполнять pthread_join () и предупреждать родительский поток, например, сигнализируя семафору о завершении дочернего потока. Этот отдельный поток может возвращать то, что получает от pthread_join (), чтобы родительский поток мог определять не только время завершения дочернего процесса, но и то, какое значение он возвращает.

Как отмечали другие, в стандартных библиотеках pthread нет неблокирующего pthread_join.

Однако, учитывая вашу заявленную проблему (пытаясь гарантировать, что все ваши потоки завершились после завершения работы программы), такая функция не нужна. Вы можете просто сделать это:

int killed_threads = 0;
for(i = 0; i < num_threads; i++) {
   int return = pthread_cancel(threads[i]);
   if (return != ESRCH)
      killed_threads++;
}
if (killed_threads)
    printf("%d threads did not shutdown properly\n", killed_threads)
else
    printf("All threads exited successfully");

Нет ничего плохого в вызове pthread_cancel для всех ваших потоков (завершенных или нет), поэтому вызов этого для всех ваших потоков не будет блокироваться и гарантирует выход потока (чистый или нет).

Это должно рассматриваться как «простой» обходной путь.

Если вы запускаете свое приложение в Linux, вам может быть интересно узнать, что:

int pthread_tryjoin_np(pthread_t thread, void **retval);

int pthread_timedjoin_np(pthread_t thread, void **retval,
                                const struct timespec *abstime);

Будьте осторожны, поскольку суффикс предполагает, что «np» означает «непереносимый». Они не являются стандартными для POSIX расширениями GNU, хотя и полезны.

ссылка на страницу руководства

Механизм pthread_join удобен, если он делает именно то, что вы хотите. Он не делает того, что вы не могли бы сделать сами, а там, где это не совсем то, что вы хотите, кодируйте именно то, что вы хотите.

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

Начните с изменения своего мышления. Застрял не поток, а то, что он делал.