pthread_join() 및 고정 실행

Question

시뮬레이션 된 시간 실행을 사용하여 시스템을 구축하려고했는데 (semaphore로 스레드 조정), 아이디어는 모든 작업주기를 1 초로 만들고 정확한 시뮬레이션을 수행했습니다. 쓰레드는 다른 모든 쓰레드가 현재 시뮬레이션 된 초에 실행을 끝내기를 기다려야한다.

주 스레드가 다른 스레드 (초보자 실수)에 합류하지 않고 작업을 완료했기 때문에 나는 정말로 성가신 메모리 누수가있었습니다. 그래서 해결하기 위해 모든 스레드에 대해 pthread_join() 지침을 추가했습니다. 모든 스레드 실행은 확인하기위한 전역 조건이있는 while 루프 안에 있었기 때문에 메인 스레드가 완료 전에 변경했습니다. 슬프게도, 이제는, 프로그램의 대부분이 실행되면서, 스레드가 끝나기를 기다리고 얼어 붙습니다.

모든 스레드 실행을 끝내고 전체 작업을 무시하는 방법을 찾아야하지만 조인이 만들어 졌는지 (메모리가 해제되었는지) 확인해야합니다.

가 지금은 오류와 컴파일 가능한 코드를 게시, 당신은 샘플 -o의 gcc로 컴파일 할 수 있습니다 -pthread sample.c에 -lm

#include <stdio.h> 
#include <stdlib.h> 
#include <string.h> 
#include <time.h> 
#include <pthread.h> 
#include <semaphore.h> 
#include <math.h> 

#define SIZE 100 
#define READY 12345 
#define END 99 
#define TIME 3600 
int *advicer; 
int *td; 
pthread_t *phones; 
sem_t *counter; 
int ready; 
int end; 

void cycle(int cycles){ 
    int i,j,k; 
    for(i = 0; i < cycles; i++){ 
     k = 1; 
     while(k){ 
      k = 0; 
      for(j = 0; j < SIZE; j++){ 
       if(advicer[j] == 0){ 
        k = 1; 
        break; 
       } 
      } 
     } 
     for(j = 0; j < SIZE; j++){ 
      advicer[j] = 0; 
      sem_post(&counter[j]); 
     } 
    } 
} 

void *do_something(void *td){ 
    int t; 
    t = *((int *) td); 
    while(end != END){ 
     if(end == END) 
      break; 
     t += t; 
     advicer[t] = 1; 
     sem_wait(&counter[t]);  
    } 
    pthread_exit(NULL); 
} 

void all_free(){ 
    int i,j; 
    end = END; 
    printf("reach %d\n",end); 
    for(i = 0; i < SIZE; i++) 
     sem_post(&counter[i]); 
    printf("reach2\n"); 
    for(i = 0; i < SIZE; i++){ 
     pthread_join(phones[i],NULL); 
    } 
    free(phones); 
    printf("reach3\n"); 
    for(i = 0; i < SIZE; i++) 
     sem_destroy(&counter[i]); 
    free(counter); 
    free(td); 
    free(advicer); 
} 

void main(){ 
    int i,my_count; 
    counter = (sem_t *)malloc(sizeof(sem_t)*SIZE); 
    advicer = (int *)malloc(sizeof(int)*SIZE); 
    td = (int *)malloc(sizeof(int)*SIZE); 
    phones = (pthread_t *)malloc(sizeof(pthread_t)*SIZE); 
    for(i = 0; i < SIZE; i++){ 
     sem_init(&counter[i], 0, 0); 
     advicer[i] = 0; 
    } 
    ready = READY; 
    my_count = 0; 
    end = 0; 
    for(i = 0; i < SIZE; i++){ 
     td[i] = i; 
     pthread_create(&(phones[i]), NULL, do_something, (void *)(&td[i])); 
    } 
    printf("starting simulation\n"); 
    while(my_count < TIME){ 
     cycle(60); 
     printf("hello\n"); 
     my_count += 60; 
    } 
    printf("simulation ended\n"); 
    all_free(); 
} 

Answer 1

다음 절에서는 잠금으로 이어질 수 :

다른 사람이 종료되지 않는 한

for(i = 0; i < m->pp; i++) 
    sem_post(&counter[i]); 
for(i = 0; i < m->pp; i++){ 
if(m->ppl[i] != NULL){ 
    phone_free(m->ppl[i]); 
} 
... 
} 

당신은 BECA, 하나 개 모두 차단하는 모든 스레드 (잠금을 해제)에만 스레드 다음 (phone_free()를 통해) pthread_join() 부르지 만, 당신이 sem_post()라는 하나 sem_post() 전화 sem_wait()에서 붙어 사용하십시오.

당신은 주요 실행 ( cycle()) 값은 이전에 최종 실행 코드 ( map_free()) pthread_join() ( phone_free()를 통해)에 전화로 스레드에 의해 인출되었을 수 있습니다 동안 sem_post()라고하지만.

스레드를 취소하려면 pthread_cancel()을 사용할 수 있습니다.

스레드가 남아 있고 pthread_join()을 호출하지 않을 때 메모리 누수를 방지하려면 pthread_detach()을 사용하여 스레드를 분리 할 수 ​​있습니다. 그런 다음 OS는 스레드가 종료 될 때 스레드의 모든 자원을 해제합니다.