Стратегия выбора места блокировки мьютекса и разблокировки в многопоточной программе

Question

в следующих фрагментах кода, мне нужно защитить connfd, потому что он может часто меняться в вызове accept().

void *deal_conn(void *arg){ 
     int connfd; 
     connfd = *((int*)arg); 
     .... 

    } 

    for(;;){ 
    connfd = accept(...); 
    pthread_create(&thread, NULL, deal_conn, &connfd); 
    } 

Я в недоумении, где можно заблокировать и разблокировать мьютексы для этой переменной. Может ли кто-нибудь дать мне несколько идей? спасибо!

Answer 1

Не передавайте адрес connfd в каждой теме, динамически выделяйте новый int и передавайте это, и у вас есть нить free(), когда больше не требуется. Поскольку нити больше не разделяют тот же ресурс не требования взаимной блокировки:

connfd = accept(...); 
if (connfd != -1) 
{ 
    int* fd = malloc(sizeof(*fd)); 
    if (fd) 
    { 
     *fd = connfd; 
     pthread_create(&thread, NULL, deal_conn, fd); 
    } 
} 

void *deal_conn(void *arg){ 
    int connfd = *((int*)arg); 

    free(arg); 
} 

Answer 2

Помимо того, я также предпочитаю решение с использованием динамически выделяемым переменным дескриптором сокета, как предложено другими, здесь есть ответ на ОПЫ-х вопрос:

void *deal_conn(void * arg) 
{ 
    int connfd = *((int *) arg); 
    /* unlock mutex here */ 
    ... 
} 

... 

/* init mutex here */ 

for(;;) 
{ 
    /* lock mutex here */ 
    int connfd = accept(...); 
    if (-1 == connfd) 
    { 
    /* in case of error unlock mutex here, as the deal_conn() will not be called */ 
    } 
    else 
    { 
    int result = pthread_create(..., deal_conn, &connfd); 
    if (-1 == result) 
    { 
     /* in case of error unlock mutex here, as the deal_conn() will not be called */ 
    } 
    } 

    ... 

Answer 3

как об изменении кода, как следующие:

void *deal_conn(void *arg){ 
      int connfd; 
      connfd = (int)arg; 
      .... 

     } 

     for(;;){ 
     connfd = accept(...); 
     pthread_create(&thread, NULL, deal_conn, (void *)connfd); 
     } 

Я не вижу необходимости блокировки connfd, connfd копируется в стек нового потока, не разделяемые потоками.