Возвращаемые значения из функций pthreads

Большинство функций pthreads при успешном выполнении возвращает 0 или номер ошибки в противном случае. Заметим, что функции pthreads не изменяют errno. Для каждой функции pthreads, которая может вернуть ошибку, в POSIX.1-2001 определено, что функция никогда не может завершиться с ошибкой EINTR.

Идентификатор нити

Каждой нити процесса назначается уникальный идентификатор нити (имеет тип pthread_t). Этот идентификатор возвращается вызывающему pthread_create(3), а в самой нити её идентификатор можно получить с помощью pthread_self(3).

Внутри процесса гарантируется уникальность идентификаторов нитей (во всех функциях pthreads, которые принимают аргумент идентификатора нити, подразумевается, что указана нить из процесса вызывающего).

Система может повторно использовать идентификатор нити после объединения завершённой нити или отсоединения завершённой нити. В POSIX сказано: «Если приложение пытается использовать идентификатор нити, у который закончился срок жизни, то поведение не предсказуемо».

Нитебезопасные функции

Нитебезопасная функция — это функция, которую можно безопасно (т. е., это приведёт к единым результатам независимо от окружения) вызывать из нескольких нитей одновременно.

В POSIX.1-2001 и POSIX.1-2008 требуется, чтобы все функции, описанные в стандарте, были нитебезопасными, за исключением следующих функций:

asctime()
basename()
catgets()
crypt()
ctermid() если передаётся аргумент не NULL
ctime()
dbm_clearerr()
dbm_close()
dbm_delete()
dbm_error()
dbm_fetch()
dbm_firstkey()
dbm_nextkey()
dbm_open()
dbm_store()
dirname()
dlerror()
drand48()
ecvt() [только POSIX.1-2001 (удалена из POSIX.1-2008)]
encrypt()
endgrent()
endpwent()
endutxent()
fcvt() [только POSIX.1-2001 (удалена из POSIX.1-2008)]
ftw()
gcvt() [только POSIX.1-2001 (удалена из POSIX.1-2008)]
getc_unlocked()
getchar_unlocked()
getdate()
getenv()
getgrent()
getgrgid()
getgrnam()
gethostbyaddr() [только POSIX.1-2001 (удалена из POSIX.1-2008)]
gethostbyname() [только POSIX.1-2001 (удалена из POSIX.1-2008)]
gethostent()
getlogin()
getnetbyaddr()
getnetbyname()
getnetent()
getopt()
getprotobyname()
getprotobynumber()
getprotoent()
getpwent()
getpwnam()
getpwuid()
getservbyname()
getservbyport()
getservent()
getutxent()
getutxid()
getutxline()
gmtime()
hcreate()
hdestroy()
hsearch()
inet_ntoa()
l64a()
lgamma()
lgammaf()
lgammal()
localeconv()
localtime()
lrand48()
mrand48()
nftw()
nl_langinfo()
ptsname()
putc_unlocked()
putchar_unlocked()
putenv()
pututxline()
rand()
readdir()
setenv()
setgrent()
setkey()
setpwent()
setutxent()
strerror()
strsignal() [добавлена в POSIX.1-2008]
strtok()
system() [добавлена в POSIX.1-2008]
tmpnam() если передаётся аргумент не NULL
ttyname()
unsetenv()
wcrtomb() если конечный аргумент NULL
wcsrtombs() если конечный аргумент NULL
wcstombs()
wctomb()

Безопасные асинхронные отменяемые функции

Безопасная асинхронная отменяемая функция (async-cancel-safe function) — это функция, которую можно безопасно вызывать в приложении, в котором разрешено асинхронная отмена (смотрите pthread_setcancelstate(3)).

Согласно POSIX.1-2001 и POSIX.1-2008 только следующие функции должны быть безопасными асинхронными отменяемыми:

pthread_cancel()
pthread_setcancelstate()
pthread_setcanceltype()

Точки отмены

В POSIX.1 определено, что некоторые функции должны, а несколько других могут было точками отмены. Если нить отменяема, её тип отменяемости откладывается, и ожидается запрос отмены нити, затем нить отменяется, когда она вызывает функцию, которая является точкой отмены.

Следующие функции должны быть точками отмены согласно POSIX.1-2001 и/или POSIX.1-2008:

accept()
aio_suspend()
clock_nanosleep()
close()
connect()
creat()
fcntl() F_SETLKW
fdatasync()
fsync()
getmsg()
getpmsg()
lockf() F_LOCK
mq_receive()
mq_send()
mq_timedreceive()
mq_timedsend()
msgrcv()
msgsnd()
msync()
nanosleep()
open()
openat() [добавлена в POSIX.1-2008]
pause()
poll()
pread()
pselect()
pthread_cond_timedwait()
pthread_cond_wait()
pthread_join()
pthread_testcancel()
putmsg()
putpmsg()
pwrite()
read()
readv()
recv()
recvfrom()
recvmsg()
select()
sem_timedwait()
sem_wait()
send()
sendmsg()
sendto()
sigpause() [только POSIX.1-2001 (перемещена в список «может» в POSIX.1-2008)]
sigsuspend()
sigtimedwait()
sigwait()
sigwaitinfo()
sleep()
system()
tcdrain()
usleep() [только POSIX.1-2001 (функция удалена в POSIX.1-2008)]
wait()
waitid()
waitpid()
write()
writev()

Следующие функции могут быть точками отмены согласно POSIX.1-2001 и/или POSIX.1-2008:

access()
asctime()
asctime_r()
catclose()
catgets()
catopen()
chmod() [добавлена в POSIX.1-2008]
chown() [добавлена в POSIX.1-2008]
closedir()
closelog()
ctermid()
ctime()
ctime_r()
dbm_close()
dbm_delete()
dbm_fetch()
dbm_nextkey()
dbm_open()
dbm_store()
dlclose()
dlopen()
dprintf() [добавлена в POSIX.1-2008]
endgrent()
endhostent()
endnetent()
endprotoent()
endpwent()
endservent()
endutxent()
faccessat() [добавлена в POSIX.1-2008]
fchmod() [добавлена в POSIX.1-2008]
fchmodat() [добавлена в POSIX.1-2008]
fchown() [добавлена в POSIX.1-2008]
fchownat() [Added in POSIX.1-2008]
fclose()
fcntl() (для любого значения аргумента cmd)
fflush()
fgetc()
fgetpos()
fgets()
fgetwc()
fgetws()
fmtmsg()
fopen()
fpathconf()
fprintf()
fputc()
fputs()
fputwc()
fputws()
fread()
freopen()
fscanf()
fseek()
fseeko()
fsetpos()
fstat()
fstatat() [добавлена в POSIX.1-2008]
ftell()
ftello()
ftw()
futimens() [добавлена в POSIX.1-2008]
fwprintf()
fwrite()
fwscanf()
getaddrinfo()
getc()
getc_unlocked()
getchar()
getchar_unlocked()
getcwd()
getdate()
getdelim() [добавлена в POSIX.1-2008]
getgrent()
getgrgid()
getgrgid_r()
getgrnam()
getgrnam_r()
gethostbyaddr() [только SUSv3 (функция удалена из POSIX.1-2008)]
gethostbyname() [только SUSv3 (функция удалена из POSIX.1-2008)]
gethostent()
gethostid()
gethostname()
getline() [добавлена в POSIX.1-2008]
getlogin()
getlogin_r()
getnameinfo()
getnetbyaddr()
getnetbyname()
getnetent()
getopt() (если opterr не равно 0)
getprotobyname()
getprotobynumber()
getprotoent()
getpwent()
getpwnam()
getpwnam_r()
getpwuid()
getpwuid_r()
gets()
getservbyname()
getservbyport()
getservent()
getutxent()
getutxid()
getutxline()
getwc()
getwchar()
getwd() [только SUSv3 (функция удалена из POSIX.1-2008)]
glob()
iconv_close()
iconv_open()
ioctl()
link()
linkat() [добавлена в POSIX.1-2008]
lio_listio() [добавлена в POSIX.1-2008]
localtime()
localtime_r()
lockf() [добавлена в POSIX.1-2008]
lseek()
lstat()
mkdir() [добавлена в POSIX.1-2008]
mkdirat() [добавлена в POSIX.1-2008]
mkdtemp() [добавлена в POSIX.1-2008]
mkfifo() [добавлена в POSIX.1-2008]
mkfifoat() [добавлена в POSIX.1-2008]
mknod() [добавлена в POSIX.1-2008]
mknodat() [добавлена в POSIX.1-2008]
mkstemp()
mktime()
nftw()
opendir()
openlog()
pathconf()
pclose()
perror()
popen()
posix_fadvise()
posix_fallocate()
posix_madvise()
posix_openpt()
posix_spawn()
posix_spawnp()
posix_trace_clear()
posix_trace_close()
posix_trace_create()
posix_trace_create_withlog()
posix_trace_eventtypelist_getnext_id()
posix_trace_eventtypelist_rewind()
posix_trace_flush()
posix_trace_get_attr()
posix_trace_get_filter()
posix_trace_get_status()
posix_trace_getnext_event()
posix_trace_open()
posix_trace_rewind()
posix_trace_set_filter()
posix_trace_shutdown()
posix_trace_timedgetnext_event()
posix_typed_mem_open()
printf()
psiginfo() [добавлена в POSIX.1-2008]
psignal() [добавлена в POSIX.1-2008]
pthread_rwlock_rdlock()
pthread_rwlock_timedrdlock()
pthread_rwlock_timedwrlock()
pthread_rwlock_wrlock()
putc()
putc_unlocked()
putchar()
putchar_unlocked()
puts()
pututxline()
putwc()
putwchar()
readdir()
readdir_r()
readlink() [добавлена в POSIX.1-2008]
readlinkat() [добавлена в POSIX.1-2008]
remove()
rename()
renameat() [добавлена в POSIX.1-2008]
rewind()
rewinddir()
scandir() [добавлена в POSIX.1-2008]
scanf()
seekdir()
semop()
setgrent()
sethostent()
setnetent()
setprotoent()
setpwent()
setservent()
setutxent()
sigpause() [добавлена в POSIX.1-2008]
stat()
strerror()
strerror_r()
strftime()
symlink()
symlinkat() [добавлена в POSIX.1-2008]
sync()
syslog()
tmpfile()
tmpnam()
ttyname()
ttyname_r()
tzset()
ungetc()
ungetwc()
unlink()
unlinkat() [добавлена в POSIX.1-2008]
utime() [добавлена в POSIX.1-2008]
utimensat() [добавлена в POSIX.1-2008]
utimes() [добавлена в POSIX.1-2008]
vdprintf() [добавлена в POSIX.1-2008]
vfprintf()
vfwprintf()
vprintf()
vwprintf()
wcsftime()
wordexp()
wprintf()
wscanf()

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

Компиляция в Linux

В Linux, программы, использующие программный интерфейс pthreads, должны компилироваться с помощью cc -pthread.

Реализации нитей POSIX в Linux

За всё время в библиотеке GNU C было две реализации нитей для Linux:

LinuxThreads

Первоначальная реализация pthreads. Начиная с glibc 2.4 эта реализация больше не поддерживается.

NPTL (библиотека нитей POSIX)

Современная реализация pthreads. По сравнению с LinuxThreads, NPTL более точно соответствует требованиям POSIX.1 и более производительна при создании большого количества нитей. NPTL появилась в glibc начиная с версии 2.3.2, и требует свойства, появившиеся в ядре Linux 2.6.

Обе реализации являются, так называемыми реализациями 1:1, то есть каждая нить отображается в планируемый элемента ядра. Обе реализации используют системный вызов Linux clone(2). В NPTL примитивы синхронизации нитей (мьютексы, объединение нитей и т .п.) реализованы с помощью системного вызова Linux futex(2).

LinuxThreads

Отличительные свойства данной реализации:

• В дополнении к главной (начальной) нити, нити программы создаются с помощью pthread_create(3), реализация создаёт «управляющую» нить. Эта нить выполняет создание и завершение нитей (что приводит к проблемам, если эта нить случайно завершится).
• Внутри реализации используются сигналы. В Linux 2.2 и новее используются первые три сигнала реального времени (смотрите также signal(7)). В старых ядрах Linux используются сигналы SIGUSR1 и SIGUSR2. В приложениях нельзя использовать набор сигналов, задействованный в реализации.
• У нитей разные ID процесса (фактически, нити LinuxThreads реализованы как процессы, у которых больше общей информации чем обычно, но которые имеют разный идентификаторы процесса). Нити LinuxThreads (включая управляющую нить) в ps(1) видимы как отдельные процессы.

Реализация LinuxThreads отклоняется от спецификации POSIX.1 в нескольких местах, а именно:

• Вызов getpid(2) возвращает разные значения для каждой нити.
• Вызов getppid(2) в нитях, кроме главной, возвращает идентификатор процесса управляющей нити; вместо getppid(2) в этих нитях будет возвращаться тоже значение, что и из getppid(2) в главной нити.
• Когда нить создаёт новый процесс-потомок с помощью fork(2), все нити должны ожидать потомка в wait(2). Однако реализация позволяет вызвать wait(2) только в нити, которая создала потомка.
• Когда нить вызывает execve(2), остальные нити завершают работу (требование POSIX.1). Однако, получаемый процесс имеет тот же PID, что и нить, которая вызвала execve(2): это должен быть тот же PID, что и у главной нити.
• У нитей разные ID пользователя и группы. Это может вызвать сложности в программах с set-user-ID и может привести к ошибкам функций pthreads, если приложение изменяет свои учётные данные с помощью seteuid(2) и подобных вызовов.
• У нитей разные ID сеанса и группы процессов.
• У нитей разные записи о блокировках, созданных fcntl(2).
• Информация, возвращаемая times(2) и getrusage(2), относится только к нити, а не к процессу в целом.
• У нитей разные значения отмен семафоров (смотрите semop(2)).
• У нитей разные интервалы таймеров.
• У нитей разные значения уступчивости.
• В POSIX.1 различаются сигналы, адресованные процессу в целом и отдельным нитям. Согласно POSIX.1, сигналы, направленные процессу (посланные, например, с помощью kill(2)), должны обрабатываться одной произвольно выбранной нитью внутри процесса. LinuxThreads не поддерживает сигналы, направленные процессу: сигналы могут посылаться только определённым нитям.
• Нити имеют разные настройки альтернативного стека сигналов. Однако, новые настройки альтернативного стека сигналов копируются из нити, которая его создаёт, так что изначально нити имеют единый альтернативный стек сигналов (новая нить должна запускаться без альтернативного стека сигналов. Если две нити обрабатывают сигналы в едином альтернативном стеке сигналов одновременно, то в программе возникнет непредсказуемая ошибка).

NPTL

В NPTL все нити процесса помещаются в одну группу нитей; все члены группы нитей имеют один PID. В NPTL нет управляющей нити.

Внутри NPTL используются первые два сигнала реального времени; эти сигналы нельзя использовать в приложениях. Подробности смотрите в nptl(7).

NPTL тоже не соответствует POSIX.1, как минимум, в одном:

-

У нитей разные значения уступчивости.

Несколько несоответствий NPTL проявляется только при работе со старыми ядрами:

• Информация, возвращаемая times(2) и getrusage(2), относится только к нити, а не к процессу в целом (исправлено в ядре 2.6.9).
• У нитей разные ограничения по ресурсам (исправлено в ядре 2.6.10).
• У нитей разные интервалы таймеров (исправлено в ядре 2.6.12).
• Только из главной нити разрешено запускать новый сеанс с помощью setsid(2) (исправлено в версии 2.6.16).
• Только из главной нити разрешено делать процесс лидером группы процессов с помощью setpgid(2) (исправлено в версии 2.6.16).
• Нити имеют разные настройки альтернативного стека сигналов Однако, новые настройки альтернативного стека сигналов копируются из нити, которая его создаёт, так что изначально нити имеют единый альтернативный стек сигналов (исправлено в ядре 2.6.16).

Также стоит учитывать следующее о реализации NPTL:

-

Если мягкое ограничение ресурса на размер стека (смотрите описание RLIMIT_STACK в setrlimit(2)) устанавливается в значение, отличное от unlimited, то это значение определяет размер стека по умолчанию для новых нитей. В целях эффективности, это ограничение должно быть установлено но выполнения программы, возможно с помощью встроенной команды оболочки ulimit -s (limit stacksize в оболочке C).

Определение реализации нитей

Начиная с glibc 2.3.2, для определение реализации нитей в системе можно использовать команду getconf(1), например:

bash$ getconf GNU_LIBPTHREAD_VERSION
NPTL 2.3.4

При наличии старых версий glibc можно использовать команду:

bash$ $(ldd /bin/ls | grep libc.so | awk '{print $3}' ) | \

                egrep -i 'threads|nptl'

        Native POSIX Threads Library by Ulrich Drepper et al

Выбор реализации нитей: LD_ASSUME_KERNEL

В системах с glibc, которая поддерживает и LinuxThreads и NPTL (например, glibc 2.3.x), можно воспользоваться переменной окружения LD_ASSUME_KERNEL для замены выбранной динамическим компоновщиков реализации нитей по умолчанию. Эта переменная указывает динамическому компоновщику считать, что он запускается с определённой версией ядра в системе. Указав версию ядра, в которой не поддержки, требуемой NPTL, его можно заставить использовать LinuxThreads (наиболее вероятной причиной для этого будет необходимость запуска (сломанного) приложения, которое зависит от некоторого не совместимого поведения LinuxThreads). Пример:

bash$ $(LD_ASSUME_KERNEL=2.2.5 ldd /bin/ls | grep libc.so | \

                awk '{print $3}' ) | egrep -i 'threads|nptl'

        linuxthreads-0.10 by Xavier Leroy