linux 多线程recv安全吗,在多线程环境中recv（）不会被信号中断

àì夳堔傛蜴生んèń 2023-01-21 09:21 1阅读 0赞

我有一个处于阻塞recv()循环中的线程，我想终止(假设不能将其更改为select()其他任何异步方法)。

我也有一个捕获的信号处理程序，SIGINT理论上它应该recv()返回错误并errno设置为EINTR。

但是事实并非如此，我认为这与应用程序是多线程的事实有关。还有另一个线程，正在等待pthread\_join()呼叫。

这里发生了什么事？

编辑：

好的，现在我将信号从主线程显式传递给所有阻塞recv()线程pthread\_kill()(这导致SIGINT安装了相同的全局信号处理程序，尽管多次调用是良性的)。但是recv()通话仍然没有畅通。

编辑：

我编写了一个代码示例来重现该问题。

主线程将套接字连接到行为异常的远程主机，该主机不会让连接断开。

所有信号均被阻止。

读取线程线程已启动。

Main解除封锁并安装的处理程序SIGINT。

读取线程解除阻塞并安装的处理程序SIGUSR1。

主线程的信号处理程序将a发送SIGUSR1到读取线程。

有趣的是，如果我替换recv()为sleep()它，就可以了。

聚苯乙烯

或者，您可以仅打开UDP套接字而不使用服务器。

客户

\#include

static void

err(const char \*msg)

perror(msg);

abort();

static void

blockall()

sigset\_t ss;

sigfillset(&ss);

if (pthread\_sigmask(SIG\_BLOCK, &ss, NULL))

err("pthread\_sigmask");

static void

unblock(int signum)

sigset\_t ss;

sigemptyset(&ss);

sigaddset(&ss, signum);

if (pthread\_sigmask(SIG\_UNBLOCK, &ss, NULL))

err("pthread\_sigmask");

void

sigusr1(int signum)

(void)signum;

printf("%lu: SIGUSR1\\n", pthread\_self());

void\*

read\_thread(void \*arg)

int sock, r;

char buf\[100\];

unblock(SIGUSR1);

signal(SIGUSR1, &sigusr1);

sock = \*(int\*)arg;

printf("Thread (self=%lu, sock=%d)\\n", pthread\_self(), sock);

r = 1;

while (r > 0)

r = recv(sock, buf, sizeof buf, 0);

printf("recv=%d\\n", r);

if (r < 0)

perror("recv");

return NULL;

int sock;

pthread\_t t;

void

sigint(int signum)

int r;

(void)signum;

printf("%lu: SIGINT\\n", pthread\_self());

printf("Killing %lu\\n", t);

r = pthread\_kill(t, SIGUSR1);

if (r)

printf("%s\\n", strerror(r));

abort();

int

main()

pthread\_attr\_t attr;

struct sockaddr\_in addr;

printf("main thread: %lu\\n", pthread\_self());

memset(&addr, 0, sizeof addr);

sock = socket(AF\_INET, SOCK\_STREAM, IPPROTO\_TCP);

if (socket < 0)

err("socket");

addr.sin\_family = AF\_INET;

addr.sin\_port = htons(8888);

if (inet\_pton(AF\_INET, "127.0.0.1", &addr.sin\_addr) <= 0)

err("inet\_pton");

if (connect(sock, (struct sockaddr \*)&addr, sizeof addr))

err("connect");

blockall();

pthread\_attr\_init(&attr);

pthread\_attr\_setdetachstate(&attr, PTHREAD\_CREATE\_JOINABLE);

if (pthread\_create(&t, &attr, &read\_thread, &sock))

err("pthread\_create");

pthread\_attr\_destroy(&attr);

unblock(SIGINT);

signal(SIGINT, &sigint);

if (sleep(1000))

perror("sleep");

if (pthread\_join(t, NULL))

err("pthread\_join");

if (close(sock))

err("close");

return 0;

服务器

import socket

import time

s = socket.socket(socket.AF\_INET)

s.setsockopt(socket.SOL\_SOCKET, socket.SO\_REUSEADDR, 1)

s.bind(('127.0.0.1',8888))

s.listen(1)

c = \[\]

while True:

(conn, addr) = s.accept()

c.append(conn)

linux 多线程recv安全吗,在多线程环境中recv（）不会被信号中断

发表评论取消回复

还没有评论，来说两句吧...

相关阅读

相关 JAVAEE---多线程线程安全

相关在多线程环境下，SimpleDateFormat是线程安全的吗?

相关单例在多线程中保证线程安全

相关 Linux多线程——使用信号量同步线程

相关 linux多线程信号总结

相关 Java多线程----线程的中断

相关为什么多线程会产生线程不安全问题？

相关多线程环境下SimpleDateFormat线程不安全问题

相关多线程：线程安全。

相关 Linux多线程——使用信号量同步线程