pthread_create의 매개변수 전달 관련 문제점
      글쓴이: 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: 
| 첨부 | 파일 크기 | 
|---|---|
| 1.48 KB | 
Forums: 


매개변수 전달은 이상없고, msgsnd(),
매개변수 전달은 이상없고,
msgsnd(), msgrcv() 를 잘못 사용하셨습니다.
메모리 침범이 발생해서 스택이 오염되었고, 그 와중에 번호를 저장한 배열이 영향을 받았습니다.
제가 어떻게 잘못 쓴건지 알 수 있을까요...?
답변 감사드립니다. 작성해주신 소스는 열심히 보겠습니다.
/***************************************************/
코드를 보면 아 이런식으로 하면 되는건가 정도만 이해가 되고
왜 제가 짠 소스는 안되는지 잘 모르겠습니다.ㅠㅠ
왜 안됬던 건가요?
man page 읽어보세요. 잘못된 부분만
man page 읽어보세요.
잘못된 부분만 추리면
제대로 돌리기 위해 최소한으로 수정한다면,
struct msg_DATA { long type; DATA data; };struct msg_DATA msg = { .type = 1, }; DATA *data = &msg.data; ... make_something(data); msgsnd(..., &msg, sizeof(*data), ...); ...댓글 달기