Как прервать поток, выполняющий соединение блокирующего сокета?

Question

У меня есть код, который порождает pthread, который пытается поддерживать соединение сокетов с удаленным хостом. Если соединение когда-либо потеряно, он пытается повторно подключиться с помощью блокирующего вызова connect() на свой сокет. Поскольку код работает в отдельном потоке, мне все равно, что он использует синхронный сокет API.

То есть, пока наступит время для моего приложения для выхода. Я хотел бы выполнить некоторое подобие упорядоченного выключения, поэтому я использую примитивы синхронизации потоков, чтобы разбудить поток и подать сигнал для его выхода, а затем выполнить pthread_join() в потоке, чтобы дождаться его завершения. Это отлично работает, если поток не находится в середине вызова connect(), когда я командую выключение. В этом случае я должен ждать подключения к тайм-ауту, что может быть длительным. Это заставляет приложение работать долгое время, чтобы закрыть его.

Что бы я хотел сделать, так это прерывать вызов connect(). После того, как вызов вернется, поток заметит мой выходной сигнал и отключится. Поскольку connect() является системным вызовом, я думал, что могу умышленно прервать его с помощью сигнала (таким образом, обратный вызов EINTR), но я не уверен, является ли это надежным методом в среде потоков POSIX.

Есть ли у кого-нибудь рекомендации относительно того, как это сделать, используя сигналы или с помощью какого-либо другого метода? В качестве примечания, вызов connect() приведен в некотором коде библиотеки, который я не могу изменить, поэтому переход на неблокирующий сокет не является вариантом.

Answer 1

Попробуйте закрыть() гнездо для прерывания connect(). Я не уверен, но я думаю, что это будет работать, по крайней мере, на Linux. Конечно, будьте осторожны, чтобы синхронизировать правильно так, чтобы вы только close() этот сокет один раз или второй close() мог теоретически закрыть несвязанный файловый дескриптор, который был только что открыт.

EDIT: выключение() может быть более целесообразным, поскольку он фактически не закрывает сокет.

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

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

С другой стороны, если в вашем рабочем потоке вы делаете нелипкая подключения() и получать уведомления через epoll_pwait() (или ppoll() или pselect(); обратите внимание на р), вы можете избежать условий гонки, связанных с сигналами.