解释Linux *** 作系统中的不可中断睡眠态的存在理由？

不可中断睡眠也就是D状态。比如内核态进程在等待某项资源，这时候是不允许被打断的，否则可能导致系统进入未知状态，或者引发严重的系统异常，所以对于这种 *** 作，定义D状态进行保护。使其在完成本次 *** 作之前，不可以被任何异步状态打断。

1.使用命令查看Linux进程的线程数 1、使用top命令,具体用法是 top -H 加上这个选项,top的每一行就不是显示一个进程,而是一个线程。 2、使用ps命令,具体用法是 ps -xH 这样可以查看所有...

2.Linux系统工具查看Linux进程 看看这个目录吧,/proc/5000/ 这里面有你所有想要的。其实stat代表着当前的一些信息。 使用ps命令来查看进程的时候,进程状态分别对应的含义如下: D 不可中断...

c++

Linux环境中使用socket进行UDP和TCP多线程通信无法关闭socket

（^v^）

原创

关注

0点赞·641人阅读

在Linux下，使用QT编程网络通信，为提高通信效率，使用原始socket进行网络编程，在QT线程中经常出现线程无法退出，原因来源于socket无法关闭。

线程处理如下：

void communicationClass::run()

{

// 开启数据处理线程

#ifdef Q_OS_LINUX

//配置服务器信息

bzero(&m_sServer_addr, sizeof(m_sServer_addr))

m_sServer_addr.sin_family = AF_INET

//设置为IPV4通信

m_sServer_addr.sin_addr.s_addr = htonl(INADDR_ANY)

//设置目的ip

m_sServer_addr.sin_addr.s_addr = inet_addr(m_strSendIP.toStdString().c_str())

//设置目的端口去链接服务器

m_sServer_addr.sin_port = htons(m_ui16Port)

//配置本地信息

bzero(&m_sLocal_addr, sizeof(m_sLocal_addr))

m_sLocal_addr.sin_family = AF_INET

//设置为IPV4通信

//loc_addr.sin_addr.s_addr = htonl(INADDR_ANY)

//设置目的ip

m_sLocal_addr.sin_addr.s_addr = htonl(INADDR_ANY)

//设置本地端口去链接服务器

m_sLocal_addr.sin_port = htons(m_ui16Port)

m_iSockedFd = socket(AF_INET, SOCK_DGRAM, IPPROTO_UDP) //设置UDP报文传输0表示默认SOCK_DGRAM 默认使用UDP

//其中第三位 0 是调用方式标志位，设置socket通方式，比如非阻塞

if(m_iSockedFd<0)

{

emit signal_networkInfoError(false, "socket create failure")

return

}

//将本地配置使用bind绑定

int ret = bind(m_iSockedFd,(struct sockaddr*)&m_sLocal_addr,sizeof (m_sLocal_addr))

if(ret <0)

{

emit signal_networkInfoError(false, "socket bind failure")

return

}

emit signal_networkInfoError(true, "network success")

// 线程循环等待数据

while (!isInterruptionRequested())

{

char buf[1600]

int count = 0

socklen_t i_server_addr_len = sizeof(m_sServer_addr)

count = recvfrom(m_iSockedFd, buf, sizeof(buf), 0, (struct sockaddr*)&m_sServer_addr,&i_server_addr_len)

if (count >0)

{

// 组装返回数据buffer

QByteArray arrayRecvData

arrayRecvData.resize(count)

memcpy(arrayRecvData.data(), buf, count)

// qDebug() <<"接收到数据:" <<arrayRecvData.size()

emit signal_recvNetworkData(arrayRecvData)

}

msleep(1)

}

#endif

#ifdef Q_OS_WIN32

// 确定版本信息

WSADATA wsaData

WSAStartup(MAKEWORD(2, 2), &wsaData)

if (LOBYTE(wsaData.wVersion) != 2 || HIBYTE(wsaData.wVersion) != 2)

{

emit signal_networkInfoError(false, "Version failure")

return

}

// 创建socket

m_socket = socket(AF_INET, SOCK_DGRAM, IPPROTO_UDP)

if (INVALID_SOCKET == m_socket)

{

emit signal_networkInfoError(false, "socket create failure")

return

}

// 初始化本地地址信息

//地址族

m_sLocal_addr.sin_family = AF_INET

//端口

m_sLocal_addr.sin_port = htons(m_ui16Port)

//IP

m_sLocal_addr.sin_addr.s_addr = htonl(INADDR_ANY)

// 初始化服务器地址信息

//地址族

m_sServer_addr.sin_family = AF_INET

//端口

m_sServer_addr.sin_port = htons(m_ui16Port)

//IP

m_sServer_addr.sin_addr.s_addr = inet_addr(m_strSendIP.toStdString().c_str())

int ret = bind(m_socket, (sockaddr*)&m_sLocal_addr, sizeof(m_sLocal_addr))

if (ret <0)

{

emit signal_networkInfoError(false, "socket bind failure")

return

}

emit signal_networkInfoError(true, "network success")

// 线程循环等待数据

while (!isInterruptionRequested())

{

char buf[1600]

// memset(buf,0,1600*sizeof(char))

int count = 0

count = recv(m_socket, buf, sizeof(buf), 0)

if (count >0)

{

// 组装返回数据buffer

QByteArray arrayRecvData

arrayRecvData.resize(count)

memcpy(arrayRecvData.data(), buf, count)

emit signal_recvNetworkData(arrayRecvData)

}

}

#endif

qDebug() <<"communicationClass quit"

}

复制

退出线程：

#ifdef Q_OS_LINUX

close(m_iSockedFd)

#endif

#ifdef Q_OS_WIN32

closesocket(m_socket)

WSACleanup()

#endif

requestInterruption()

复制

在windows下线程能优雅退出。

但在Linux中会出现close（）关闭socket失败。

解决方法：

#include<sys/socket.h>

int shutdown(int sockfd,int how)

TCP连接是双向的(是可读写的),当我们使用close时,会把读写通道都关闭,有时侯我们希望只关闭一个方向,这个时候我们能够使用shutdown.

how的方式有三种分别是

SHUT_RD（0）：关闭sockfd上的读功能，此选项将不允许sockfd进行读 *** 作。

SHUT_WR（1）：关闭sockfd的写功能，此选项将不允许sockfd进行写 *** 作。

SHUT_RDWR（2）：关闭sockfd的读写功能。

成功则返回0，错误返回-1，错误码errno：EBADF表示sockfd不是一个有效描述符；ENOTCONN表示sockfd未连接；ENOTSOCK表示sockfd是一个文件描述符而不是socket描述符。

---