스레드 종료, 전체 프로그램 종료?

Question

다음 루프는 프로그램의 주요 내용입니다. 들어오는 연결을 받아들이고 스레드와 함께 작동합니다.

문제는 모든 스레드가 종료 되 자마자 전체 프로그램을 종료한다는 것입니다. 코드는 다음과 같습니다.

#include <sys/socket.h> 
#include <sys/types.h> 
#include <netdb.h> 
#include <netinet/in.h> 
#include <arpa/inet.h> 
#include <unistd.h> 
#include <stdio.h> 
#include <stdlib.h> 
#include <string.h> 
#include <time.h> 
#include <pthread.h> 
#define BUFLEN 1500 
#define MAXCON 30 

char *returnTimeDate(int inputchoice); 
void readWriteToClient(int inputconnfd); 

int main(){ 

    int backlog = 10; 

    int fd; 
    fd = socket(AF_INET, SOCK_STREAM, 0); 
    if (fd == -1) { 
     // Error: unable to create socket 
    } 

    struct sockaddr_in cliaddr; 
    socklen_t cliaddrlen = sizeof(cliaddr); 

    struct sockaddr_in addr; 
    addr.sin_addr.s_addr = INADDR_ANY; 
    addr.sin_family = AF_INET; 
    addr.sin_port = htons(5001); 

    if (bind(fd, (struct sockaddr *) &addr, (socklen_t) sizeof(addr)) == -1) { 
     fprintf(stderr,"Bind Didn't Work\n"); 
    } 

    if (listen(fd, backlog) == -1) { 
     fprintf(stderr,"Listen Didn't Work\n"); 
    } 

    pthread_t *threadsArray = (pthread_t *)calloc(MAXCON, sizeof(pthread_t)); 
    pthread_t *threadPtr = threadsArray; 

    int k; 
    for(k = 0; k < MAXCON; k++){ 
     fprintf(stderr,"Make %d\n",k); 
     int connfd; 
     connfd = accept(fd, (struct sockaddr *) &cliaddr, &cliaddrlen); 
     if (connfd == -1) { 
      fprintf(stderr,"Accept Didn't Work\n"); 
     } 
     fprintf(stderr,"Waited\n",k); 
     pthread_create(&threadPtr, NULL, readWriteToClient, (void *)connfd); 
     threadPtr++; 
    } 

    pthread_t *threadPtrJoin = threadsArray; 

    for(k = 0; k < MAXCON; k++){ 
     fprintf(stderr,"Join %d\n",k); 
     pthread_join(*threadPtrJoin, NULL); 
     threadPtrJoin++; 
    } 

/* readWriteToClient(connfd);*/ 

    close(fd); 

    return 0; 

} 

void readWriteToClient(int inputconnfd){ 

    int connfd = inputconnfd; 

    while(1){ 

     char *dateString = "DATE\r\n"; 
     char *timeString = "TIME\r\n"; 
     char *endString = "end"; 

     char *bufferTime = returnTimeDate(0); 
     char *bufferDate = returnTimeDate(1); 

     ssize_t i; 
     ssize_t rcount; 
     char buf[BUFLEN]; 
     char *toReturn = (char *)malloc(BUFLEN*sizeof(char)); 
     rcount = read(connfd, buf, BUFLEN); 
     if((strcmp (buf, dateString)) == 0){ 
      strcpy(toReturn, bufferDate); 
     } 
     if((strcmp (buf, timeString)) == 0){ 
      strcpy(toReturn, bufferTime); 
     } 
     if((strcmp (buf, endString)) == 0){ 
      goto outside; 
     } 
     if (rcount == -1) { 
      // Error has occurred 
      printf("Error: rcount -1"); 
     } 

/*  fprintf(stderr,"I have received = %s\n",buf);*/ 

     if (write(connfd, toReturn, BUFLEN) == -1) { 
      fprintf(stderr,"I didn't write = %s\n",buf);  
     } 
    } 

    outside: return; 

} 

char *returnTimeDate(int inputchoice){ 

    time_t timer; 
    char *bufferTimee = (char *)malloc(25*sizeof(char)); 
    char *bufferDatee = (char *)malloc(25*sizeof(char)); 
    struct tm* tm_info; 
    time(&timer); 
    tm_info = localtime(&timer); 
    strftime(bufferTimee, 25, "%H:%M:%S\n\0", tm_info); 
    strftime(bufferDatee, 25, "%d:%m:%Y\n\0", tm_info); 

    if(inputchoice == 0){ 
     return bufferTimee; 
    }else{ 
     return bufferDatee; 
    } 

} 

왜 이렇게할까요?

Answer 1

이 몇 가지 있습니다 작동하는지 알려주세요 다음

void *readWriteToClient(void *inputconnfd) 

와

void readWriteToClient(int inputconnfd) 

이

int connfd = *((int *) inputconnfd); 

와 지역 변수에 할당 변경 그게 당신 pthreads의 사용에 매우 잘못되었습니다. 모든

첫째, 난 당신이 의미 생각 : 우리는 st에 pthread_create()의 반환 값을 저장하고

• 과 오류 사건을 처리 :

  int st = pthread_create(&threadPtr[k], NULL, readWriteToClient, (void *)connfd); 
  if (st != 0) { 
      /* handle error */ 
  } 
  

  참고 다음.

• &threadPtr (pthread_t **)이 아닌 &threadPtr[k] (유형이 pthread_t *)입니다. 이것은 문제의 원인 일 가능성이 큽니다.

하지만 난 당신의 코드를 가지고있는 주요 문제 중 하나, 당신은 pthread_create()에 readWriteToClient를 전달하여 정의되지 않은 동작을 호출 할 것입니다.pthread_create 프로토 타입은 다음과 같다 :

int pthread_create(pthread_t *restrict, 
        const pthread_attr_t *restrict, 
        void *(*start_routine)(void*), 
        void *restrict arg); 

당신이 &threadPtr&threadPtr[k]로 변경하더라도, 당신은 다음과 같이 호출 할 것 :

int pthread_create(pthread_t *restrict, 
        const pthread_attr_t *restrict, 
        void (*start_routine)(int),  // oops! 
        void *restrict arg); 

그래서는 pthread_create() 하나의 함수에 대한 포인터를 받아 들인다 다른 유형의 함수 (C11, 6.7.6.3/15, 강조 광산)에 대한 포인터를 전달하고 있습니다 :

두 가지 재미를 위해 호환 될 수있는 형식이면 호환 가능한 반환 형식을 지정해야합니다. 또한 매개 변수 유형 목록이 둘 다 존재하는 경우 매개 변수 수와 줄임표 종료 문자 사용시 동의해야합니다. 해당 매개 변수는 호환 유형이어야합니다. [...]

함수에 대한 포인터는 암시 적으로 변환되고, 함수 어쨌든라고하지만,이 표준 (C11, 6.3.2.3/8 강조 광산)에 따라, 불법 :

한 유형의 함수에 대한 포인터가 다른 유형의 함수에 대한 포인터로 변환 될 수 있습니다. 결과는 과 원래 포인터를 비교해야합니다. 형식이 참조 된 형식과 호환되지 않는 함수를 호출하는 데 변환 포인터를 사용하는 경우 동작은 정의되지 않음입니다.

정의되지 않은 동작을 호출하기 때문에 코드를 실행 한 후에 코드가 어떻게 동작하는지 알 수 없습니다.

또한 int을 void *으로 변환 한 다음 정보를 잃지 않고 (구현 정의 됨) 보장 할 수 없으므로주의해야합니다.

경고가 컴파일 된 상태에서 컴파일해야하는 코드에는 몇 가지 다른 오류가 있습니다. 즉, 은 항상이어야합니다.

Answer 2

나는

나의 제안은 컴파일 단계에서 매주 경고를 해결하려면 입니다 .... 컴파일러가 호환되지 않는 포인터 유형에 대한 몇 가지 경고 yelding이었다 내기.

이 작업을 수행했다면 pthread 함수의 매개 변수는 int가 아니라 void에 대한 포인터 여야합니다.

게다가 후자의 함수는 스택에 큰 혼란을 가져올 수있는 void가 아닌 void에 대한 포인터를 반환해야합니다.

먼저 변경하고 다음

connfd[k] = accept(fd, (struct sockaddr *) &cliaddr, &cliaddrlen); 

에 connfd 저장

int connfd[MAXCON]; 

FDS 연결 배열을 사용

pthread_create(threadPtr, NULL, readWriteToClient, connfd); 

pthread_create(threadPtr, NULL, readWriteToClient, (void *) &connfd[k]); 

와

하고