1

我有一个线程，它在这样的循环中从原始 HCI 套接字读取消息：

void* loop_hci (void* args) {
    params_hci_t* params = (params_hci_t*) args;
    int result_hci = 0;
    uint8_t* buf_hci = calloc(1, HCI_EVENT_MAX_LENGTH);
    while (!poll_end()) {
        result_hci = read(params->hci_sock, buf_hci, HCI_EVENT_MAX_LENGTH);
        if (result_hci > 0) {
            // ... do stuff with the received data
        }
    }
    ancs_pdebug("HCI loop shutting down...");
    return NULL;    
}

该poll_end()功能可以正常工作并按预期工作。它在收到 SIGINT 信号之前返回 0，之后返回 1。

在主线程中，我创建这样的套接字：

hci_sock = socket(AF_BLUETOOTH, SOCK_RAW, BTPROTO_HCI);

还有线程：

ph->hci_sock = hci_sock;
pthread_create(&t_hci, NULL, &loop_hci, ph);

然后像这样（在主线程中）调用关闭一段时间后：

shutdown(hci_sock, SHUT_RD);

我假设 read() 应该在我调用 shutdown() 后返回，我在 L2CAP 套接字的不同线程中使用相同的方法并且它工作正常。但事实并非如此。我pthread_join(t_hci, NULL)在主线程中的调用永远不会返回。

插座工作正常。我可以从中读取消息。我也尝试调用 close （我在线程结束后调用），但结果是一样的。

可能是什么问题，或者我的假设是错误的？

4

1 回答 1

2

您遇到的问题可能是因为您处理套接字和多线程的方式。您不应该将 shutdown 与原始套接字一起使用。它适用于连接的套接字，我真的从未尝试过使用原始套接字或数据包套接字。但是有一个建议是杀死或取消我会避免的线程，因为杀死线程是蛮力的，并且您有不以有序方式处理资源的风险。相反，您应该以不同的方式设计您的解决方案：

  1. 一种可能性是将非阻塞套接字与 select、poll 或 epoll 一起使用。您将有一个循环在 select/poll/epoll 中等待，直到套接字准备好或超时。当你想关闭一个套接字时，你只需设置一个变量，例如 endLoop 为 true，表示轮询线程应该离开循环。参见 man 进行选择： http: //man7.org/linux/man-pages/man2/select.2.html

  2. 其他可能性，例如在 Thrift 服务器中使用，是让应用程序使用特定代码向自身发送特殊消息。侦听线程解除阻塞并读取此特殊消息，指示它应该检查是否必须完成侦听（例如通过读取变量值）。

因此，当他的侦听线程正在侦听或读取时，主线程会将变量 endLoop 变量设置为 true 以指示它完成，否则它将执行 (2) 来解除侦听线程的阻塞。

这两个选项是处理您的问题的优雅方法。要么使用非阻塞套接字 (1)，要么通过向自身发送消息来解除阻塞的读取或侦听线程。

于 2016-05-31T00:27:01.843 回答