1

我正在编写一个多线程服务器应用程序，它会回显客户端发送的任何内容。我为每个新客户生成一个线程。我已经使用while(1)循环无限期地处理连续的客户端（不是完全无限期，我已将其强制限制为 64，之后它拒绝任何新连接）。现在我需要在我的服务器应用程序中处理 Ctrl+C 信号。

一个问题是它不建议在多线程应用程序中使用signal()。

但是，即使我使用它来捕获SIGINT信号（来自 Ctrl+C）使用SO 已经讨论过的方法，这也是我需要做
的：1）服务器不应再接受更多客户端。
2) 与服务器的当前连接应该继续，除非客户端选择断开连接。

我的信号处理函数是：

void Ctrl_C_handler(int sig)
{
    if(sig == SIGINT)       // Ctrl+C
    {
        printf("Ctrl+C detected by server !!\n");
        printf("No more connections will be accepted!!");
        pthread_cancel(main_thread_id);
    }
}

我建议在 main() 中使用来取消线程的方法是：

// Method 1
pthread_setcanceltype(PTHREAD_CANCEL_ASYNCHRONOUS, NULL);
while(1)
{
    pthread_setcancelstate(PTHREAD_CANCEL_ENABLE, NULL);
    pthread_setcancelstate(PTHREAD_CANCEL_DISABLE, NULL);

            // ..
            // client handling
            // ..
}

// Method 2

while(1)
{   
    pthread_testcancel();       // Create Cancellation point
            // ..
            // client handling
            // ..
}

// Method 3

while(1)
{
    pthread_setcancelstate(PTHREAD_CANCEL_ENABLE, NULL);
    pthread_testcancel();
    pthread_setcancelstate(PTHREAD_CANCEL_DISABLE, NULL);
            // ..
            // client handling
            // ..
}

我使用的原因pthread_cancel()：

根据此链接，线程最终将使用pthread_exit()（满足要求 1）终止。由于注释部分pthread_exit()解释说它允许其他线程继续执行（满足要求 2）。

现在，如果我一直到这里，

哪种方法最适合取消线程。
我选择了方法 3，因为：

（缺点）方法1：如果线程分配内存，异步线程取消是不安全的（正如我在SO中的回答中看到的那样），以及其他一些原因

（缺点）方法2：根据这个链接有很多其他功能也可以作为取消点，其中一些我将在我的代码中使用。

（优点）方法3：与方法2类似，但更安全，因为线程被取消禁用，其他取消点将不活动。

请告诉我我的方法是否正确？它错了，除了使用 pthread_cancel() 之外，还有其他更好的方法来处理 Ctrl+C 吗？

4

1 回答 1

2

我建议避免取消。

相反，注册一个 SIGINT 处理程序，该处理程序 close()s 服务器的侦听套接字。（为此使用sigaction。）在套接字关闭后，主线程可以正常退出，让所有客户端线程继续运行。

例如在伪代码中：

static int listen_fd = -1               // server socket

void handle_SIGINT(int s):              // Requirement 1
  if listen_fd >= 0:
    close(listen_fd)
    listen_fd = -1

int main(...):
  listen_fd = new_listening_socket(...)
  block_signal(SIGINT)
  trap_signal(SIGINT, handle_SIGINT)    // again, calls sigaction

  while 1:
    unblock_signal(SIGINT)
    new_client = accept(listen_fd)
    block_signal(SIGINT)

    if new_client < 0:                  // Requirement 1, also general error handling
      break

    spawn_worker_thread(new_client)     // probably attr PTHREAD_CREATE_DETACHED

  pthread_exit(NULL)                    // Requirement 2
  return 0                              // not reached

当然，您可以根据需要包括更细微的错误处理、清理例程等。

于 2013-08-21T14:36:18.477 回答