1

我正在尝试创建一个并发 TCP 服务器，它接受多个（N 个连接），其中 N 是已知的。（例如 N = 8）所以我正在尝试创建一个预线程 TCP 服务器。

......

    for(i=0;i<NUMBER_OF_CONNECTIONS;i++)
    {
       CreateThreads(i);         
    }

    return 0;
}

//Create threads to handle the connection
void CreateThreads( int i )
{
  pthread_create(&thread_tid[i], NULL, thread_function, (void *) i);

  return; 
}

void* thread_function(void *arg)
{
        puts("In thread_function");
        int    client_soc,clilen;

        struct sockaddr_in *clientaddr;

        if( (clientaddr = malloc(addrlen)) == NULL)
          printf("malloc Error\n");

        printf("thread %d starting\n", (int) arg);
        while(1)
        {

                clilen = sizeof(struct sockaddr_in);
                pthread_mutex_lock(&mlock);

                puts("Calling accept \n");
                if ( (client_soc = accept(socket_desc, (struct sockaddr *)&clientaddr,(socklen_t*)&clilen)) < 0)
                {
                    printf("accept error\n");
                }
                pthread_mutex_unlock(&mlock);

                printf("Process Request...calling connection handler \n");
                connection_handler(client_soc);              /* process request */
                close(client_soc);
        }
}

//This will handle connection for each client
void *connection_handler(void *socket_desc)
{
    //Receive and process.....  
    return 0;
}

在上面的代码中，创建了线程并调用了 thread_function()，但它没有按预期工作。该程序在调用 thread_function() 后结束，直到创建了几个线程。我实际上希望创建“N”个线程并等待客户端连接（使用accept（））。连接后，我想接收/收集数据（或）发送命令等。这就是我有 connection_handler() 的原因，但在那之前我被卡住了。

任何人都可以尝试更正 thread_function() 函数吗？我有点卡在这里。谢谢。 更新 该程序基于 http://www.cse.fau.edu/~jie/research/publications/Publication_files/roussevwu.pdf 查看第 3.2 节以了解如何使用锁定和接受。

4

1 回答 1

5

调用thread_function()后程序结束

问题是在创建线程后，主线程会通过并结束程序。你应该打电话pthread_join。

你的方法有问题。在你的代码中你锁定mlock然后你accept(2)。您正在关键部分调用阻塞函数。这严重限制了并行性，从而破坏了线程的大部分用途。

您可以尝试一种方法，其中主线程accepts 并将新套接字分派给线程。

于 2013-02-21T13:12:57.120 回答