fork 구문을 쓰레드 구문으로 변경하고 싶은데 어떻게 해야할까요?

int wait_sock(port)
int port;
{
    int newsockfd, clilen, childpid;
    struct sockaddr_in    cli_addr, serv_addr;
    char sbuf[512];
    static int opt=1;
    int runProcess = 0;
 
    if ( (sockfd = socket(AF_INET, SOCK_STREAM, 0)) < 0)
        perror("server: can't open stream socket");
 
    bzero((char *) &serv_addr, sizeof(serv_addr));
    serv_addr.sin_family      = AF_INET;
    serv_addr.sin_addr.s_addr = htonl(INADDR_ANY);
    serv_addr.sin_port        = htons(port);
    setsockopt (sockfd, SOL_SOCKET, SO_REUSEADDR, (char *)&opt, sizeof (opt));
    while(1)
    if(bind(sockfd, (struct sockaddr *) &serv_addr, sizeof(serv_addr))<0)
    {
        proc_log("bind port = %d\n",port);
        perror("msghandle : can't bind local address");
        sleep(3);
    }
    else break;
 
    listen(sockfd, 5);
 
    signalSet(server_close);
    signal(SIGCHLD,  SIG_IGN); 
    signal(SIGALRM,  SIG_Alarm); 
 
    while(1){
        alarm(10);
        clilen = sizeof(cli_addr);
        newsockfd = accept(sockfd, (struct sockaddr *) &cli_addr, &clilen);
 
        alarm(0);
        if (newsockfd < 0) continue;
        sock = newsockfd;
 
        proc_log("Connected \n");
#ifdef _FORK_
        if ( (childpid = fork()) < 0)
        {
            perror("server: fork error");
            wait(0);
        }else if (childpid == 0) {    /* child process */
            close(sockfd);        /* close original socket */
            runProcess ++;
#endif
            wait_loop(newsockfd, port);
 
            //proc_log("msghandle Disconnected...");
#ifdef _FORK_
            close(newsockfd);
            exit(0);
        }
#endif
        proc_log("msghandle Disconnected...");
#ifdef _FORK_
        close(newsockfd);        /* parent process */
#endif
    }
    runProcess = 0;
}

typedef struct nThread
{
   int tSock;
   int tPort;
}THREAD;
 
int wait_sock(port)
int port;
{
    int newsockfd, clilen, childpid;
    struct sockaddr_in    cli_addr, serv_addr;
    char sbuf[512];
    static int opt=1;
    int runProcess = 0;
    pthread_t p_thread;
    THREAD st;
 
    if ( (sockfd = socket(AF_INET, SOCK_STREAM, 0)) < 0)
        perror("server: can't open stream socket");
 
    bzero((char *) &serv_addr, sizeof(serv_addr));
    serv_addr.sin_family      = AF_INET;
    serv_addr.sin_addr.s_addr = htonl(INADDR_ANY);
    serv_addr.sin_port        = htons(port);
    setsockopt (sockfd, SOL_SOCKET, SO_REUSEADDR, (char *)&opt, sizeof (opt));
    while(1)
    if(bind(sockfd, (struct sockaddr *) &serv_addr, sizeof(serv_addr))<0)
    {
        proc_log("bind port = %d\n",port);
        perror("msghandle : can't bind local address");
        sleep(3);
    }
    else break;
 
    listen(sockfd, 5);
 
    signalSet(server_close);
    signal(SIGCHLD,  SIG_IGN); 
    signal(SIGALRM,  SIG_Alarm); 
 
    while(runProcess < MAX_FORK_CNT){
        alarm(10);
        clilen = sizeof(cli_addr);
        newsockfd = accept(sockfd, (struct sockaddr *) &cli_addr, &clilen);
 
        alarm(0);
        if (newsockfd < 0) continue;
        sock = newsockfd;
 
        proc_log("Connected \n");
 
        st.tSock = newsockfd;
        st.tPort = port;
 
        childpid = pthread_create(&p_thread, NULL, wait_loop, (void *)&st);
 
        if(childid < 0)
            exit(0);
 
        pthread_join(p_thread, (void **)&status);
        //proc_log("msghandle Disconnected...");
        close(newsockfd);
        exit(0);
 
        proc_log("msghandle Disconnected...");
    }
    runProcess = 0;
}