현재 위치

홈 ›› Forums ›› 공부 ›› 프로그래밍 QnA

pthread_create의 매개변수 전달 관련 문제점

bluesaiha의 이미지
글쓴이: bluesaiha / 작성시간: 수, 2012/08/22 - 10:13오전 

#include<stdio.h>
#include<stdlib.h>
#include<unistd.h>
#include<pthread.h>
#include<string.h>
#include<sys/msg.h>
#include<sys/ipc.h>
#include<sys/types.h>
#include"data.h"
 
#define THRSIZ 10
//#define THRSIZ 10
 
int msgq[THRSIZ];
key_t key[THRSIZ];
 
int threadNum[THRSIZ];
pthread_mutex_t a_mutex = PTHREAD_MUTEX_INITIALIZER;
 
void *threadhandler(void *num)
{
    int len;
    int myNum;          //Thread를 생성할 때 넘겨준 식별 번호
    DATA data;              //전송 받을 데이터 구조체
    int handleCount = 0;    //각 Thread가 몇개의 데이터를 처리 했는지에 대한 카운터
    int no; 
 
    myNum = *((int *)num);
    initDATA(&data);
    printf("my thread number is %d\n",myNum);
 
msgrcv(msgq[myNum],&data, sizeof(DATA),0,0);          //해당부분을 주석 처리 하게 되면 myNum값이 제대로 출력 됨
 
    printf("[ %d ]data.no : %d HC : %d\n",myNum,data.no,handleCount);
    sleep(1);   
    printf("[AFTER] my thread number is %d\n",myNum); 
}
 
void initmsgqvariable()
{
    int i=0;
    int ret;
    pthread_t pthread[THRSIZ];
 
    for(i=0; i<THRSIZ; i++)
    {   
        threadNum[i] = i;  
    }   
 
    for(i=0; i<THRSIZ; i++)
    {
 
        msgq[i] = msgget(key[i],IPC_CREAT|0644);
        if(msgq[i] < 0)
        {
            printf("Error : MSG Queue\n");
        }
 
        ret = pthread_create(&pthread[i],NULL,threadhandler,&(threadNum[i]));
        if(ret < 0)
        {
            printf("Error : Pthread_create\n");
        }
        else
        printf("Pthread %d is created\n",threadNum[i]);
    }
    usleep(500);
}
 
int main()
{
    int i=0;
    int ret;
    DATA data;
 
    for(i=0; i<THRSIZ; i++)
    {
        key[i] = ftok("./WORK",i);
    }
 
    initmsgqvariable();
 
    sleep(2);
 
    for(i=0; i<10; i++)
    {
        setData(&data,i,2,3,4,"one","two","three");
        ret = msgsnd(msgq[i%THRSIZ], (void *)&data, sizeof(DATA), IPC_NOWAIT);
 
        if(ret < 0)
        {
            perror("MSGSND");
            sleep(1);
            i--;
        }
    }
    sleep(1);
    return 0;
}

다수의 MSGQ가 존재하고 그 각각의 MSGQ당 하나의 Thread가 메시지를 읽어서 처리하는 구조를 만드려고합니다.
소스코드를 보시면 메시지큐와 Thread를 생성 후 Thread에 대해서 넌 몇번 Thread다 라는 정보를 매개변수로 전달하는데 해당 값이 msgrcv 함수 이후 변화가 일어납니다. ㅠ

제 지식으로는 왜 이러는 지 알수가 없습니다.ㅠㅠ

도와주세요.....

파일 첨부합니다

File attachments: 
첨부파일 크기
Package icon question.zip1.48 KB
Forums: 
프로그래밍 QnA
bushi의 이미지

글쓴이: bushi / 작성시간: 수, 2012/08/22 - 3:54오후

매개변수 전달은 이상없고,
msgsnd(), msgrcv() 를 잘못 사용하셨습니다.
메모리 침범이 발생해서 스택이 오염되었고, 그 와중에 번호를 저장한 배열이 영향을 받았습니다.

댓글 첨부 파일: 
첨부파일 크기
Plain text icon mq.c.txt3.95 KB
bluesaiha의 이미지

글쓴이: bluesaiha / 작성시간: 수, 2012/08/22 - 5:49오후

답변 감사드립니다. 작성해주신 소스는 열심히 보겠습니다.

/***************************************************/
코드를 보면 아 이런식으로 하면 되는건가 정도만 이해가 되고

왜 제가 짠 소스는 안되는지 잘 모르겠습니다.ㅠㅠ

왜 안됬던 건가요?

bushi의 이미지

글쓴이: bushi / 작성시간: 수, 2012/08/22 - 8:14오후

man page 읽어보세요.

잘못된 부분만 추리면

DATA data;
...
make_something(&data);
msgsnd(..., &data, sizeof(DATA), ...);
...

DATA data;
...
msgrcv(..., &data, sizeof(DATA), ...);
parse_something(&data);
...

제대로 돌리기 위해 최소한으로 수정한다면,

struct msg_DATA {
   long type;
   DATA data;
};

struct msg_DATA msg = { .type = 1, };
DATA *data = &msg.data;
...
make_something(data);
msgsnd(..., &msg, sizeof(*data), ...);
...

struct msg_DATA msg;
DATA *data = &msg.data;
...
msgrcv(..., &msg, sizeof(*data), ...);
parse_something(data);
...

둘러보기