쓰레드 폴 생성시 개수를 define에 정의 하지 않고 설정파일에서

ljksky의 이미지

쓰레드 폴 생성시 개수를 define에 정의 하면 구조체들을
Threads thread_pool[NUMBER_OF_THREADS];
pthread_mutex_t mutex[NUMBER_OF_THREADS];
pthread_cond_t cond[NUMBER_OF_THREADS];
이렇게 선언하면 되는데..

define 하지 않고 설정파일에서 읽어 올때에는
어떻게 선언하고 사용해야하는지 모르겠습니다.

.
.
.

#define INI_FILE_NAME   "./dbcli.conf"
#define NUMBER_OF_THREADS 5

typedef struct thr_info {
pthread_t tid;
int client_fd;
int client_port;
int is_enabled;
char client_ip[16];
char data[200];
} Threads;



int thread_cnt;

Threads thread_pool[NUMBER_OF_THREADS];
pthread_mutex_t mutex[NUMBER_OF_THREADS];
pthread_cond_t cond[NUMBER_OF_THREADS];
struct sockaddr_in clientaddr[NUMBER_OF_THREADS];



int initThreads(){
        int i, ret = 0;
        char print_buf[512];
        pthread_t thread_id;


        for(i = 0; i < NUMBER_OF_THREADS; i++){
                pthread_mutex_init(&mutex[i], NULL);
                pthread_cond_init(&cond[i], NULL);
        }

        for(i = 0; i < NUMBER_OF_THREADS; i++){
                thread_pool[i].client_fd = -1;
                thread_pool[i].is_enabled = 0;
                ret = pthread_create(&thread_pool[i].tid, NULL,processClientRequest, &thread_pool[i].tid);

                if(ret != 0) {
                        perror("pthread");
                        sprintf(print_buf,"pthread_create ERROR [%d]\n", ret);
                        Print(print_buf);
                        log_write(print_buf);
                        return 1;
                }
        }
        return 0;
}


void *processClientRequest(void *data) {
        pthread_t *tid = (pthread_t *)data;
        long sec, usec;


        for(index = 0; index < NUMBER_OF_THREADS; index++) {
                if(thread_pool[index].tid == *tid) {
                       sprintf(print_buf, "THREAD INDEX .. [%d]...\n", index);
                       Print(print_buf);
                        log_write(print_buf);
                        break;
                }
        }

        for(;;){
                if(thread_pool[index].is_enabled == 0) {
                        pthread_mutex_lock(&mutex[index]);
                        pthread_cond_wait(&cond[index], &mutex[index]);
                        /*continue;*/
                }


	/**
		작업.. 루틴..
	**/


               thread_pool[index].is_enabled = 0;
               sprintf(print_buf, "**** thread_pool[index].is_enabled = [%d]\n", thread_pool[index].is_enabled);
               Print(print_buf);
               pthread_mutex_unlock(&mutex[index]);


	}           
}

void Thread_pool(int client_sockfd, char *data_buf){
        int i;
        char mprint_buf[512];

        for(i = 0; i < NUMBER_OF_THREADS; i++) {

                if(thread_pool[i].is_enabled == 0) {
                        sprintf(mprint_buf, "**** CHECK IN thread...number [%d] \n", i);
                        Print(mprint_buf);

                        pthread_mutex_unlock(&mutex[i]);
                        pthread_mutex_lock(&mutex[i]);

                        thread_pool[i].client_fd = client_sockfd;
                        thread_pool[i].is_enabled = 1;
                        thread_pool[i].client_port = ntohs(clientaddr.sin_port);
                        strncpy(thread_pool[i].client_ip, inet_ntoa(clientaddr.sin_addr), strlen(inet_ntoa(clientad
dr.sin_addr)));
                        strncpy(thread_pool[i].data, data_buf, strlen(data_buf));

                        pthread_cond_signal(&cond[i]);
                        pthread_mutex_unlock(&mutex[i]);
                        break;
                }
        }
}



int main(int argc, char *argv[]){
        int server_sockfd;
        int client_len;
        int pid, i;
        int count=0;
        int read_size=0;
        char mprint_buf[512];

        pthread_t chld_thr;

        char read_buf[200];
        char szBuff[200];

       read_config(); //설정파일을 읽어 생성 쓰레드 개수를 thread_cnt에 담는다
        if(initThreads() != 0) {
                log_write("Cannot initialize threads...\n");
                fprintf(stderr, "Cannot initialize threads...\n");
                return 1;
        }

        while(1){
                memset(read_buf, 0x00, sizeof(read_buf));
                read_size = read(server_sockfd, read_buf, sizeof(read_buf));
               Thread_pool(server_sockfd, read_buf);
        }
}
tombraid의 이미지

Threads thread_pool[NUMBER_OF_THREADS];
pthread_mutex_t mutex[NUMBER_OF_THREADS];
pthread_cond_t cond[NUMBER_OF_THREADS];

Threads *thread_pool;
pthread_mutex_t *mutex;
pthread_cond_t *cond;

이렇게 선언하고

설정에서 스레드 개수를 읽은뒤에 alloc 해서 사용하면 될꺼 같은데요

댓글 달기

Filtered HTML

  • 텍스트에 BBCode 태그를 사용할 수 있습니다. URL은 자동으로 링크 됩니다.
  • 사용할 수 있는 HTML 태그: <p><div><span><br><a><em><strong><del><ins><b><i><u><s><pre><code><cite><blockquote><ul><ol><li><dl><dt><dd><table><tr><td><th><thead><tbody><h1><h2><h3><h4><h5><h6><img><embed><object><param><hr>
  • 다음 태그를 이용하여 소스 코드 구문 강조를 할 수 있습니다: <code>, <blockcode>, <apache>, <applescript>, <autoconf>, <awk>, <bash>, <c>, <cpp>, <css>, <diff>, <drupal5>, <drupal6>, <gdb>, <html>, <html5>, <java>, <javascript>, <ldif>, <lua>, <make>, <mysql>, <perl>, <perl6>, <php>, <pgsql>, <proftpd>, <python>, <reg>, <spec>, <ruby>. 지원하는 태그 형식: <foo>, [foo].
  • web 주소와/이메일 주소를 클릭할 수 있는 링크로 자동으로 바꿉니다.

BBCode

  • 텍스트에 BBCode 태그를 사용할 수 있습니다. URL은 자동으로 링크 됩니다.
  • 다음 태그를 이용하여 소스 코드 구문 강조를 할 수 있습니다: <code>, <blockcode>, <apache>, <applescript>, <autoconf>, <awk>, <bash>, <c>, <cpp>, <css>, <diff>, <drupal5>, <drupal6>, <gdb>, <html>, <html5>, <java>, <javascript>, <ldif>, <lua>, <make>, <mysql>, <perl>, <perl6>, <php>, <pgsql>, <proftpd>, <python>, <reg>, <spec>, <ruby>. 지원하는 태그 형식: <foo>, [foo].
  • 사용할 수 있는 HTML 태그: <p><div><span><br><a><em><strong><del><ins><b><i><u><s><pre><code><cite><blockquote><ul><ol><li><dl><dt><dd><table><tr><td><th><thead><tbody><h1><h2><h3><h4><h5><h6><img><embed><object><param>
  • web 주소와/이메일 주소를 클릭할 수 있는 링크로 자동으로 바꿉니다.

Textile

  • 다음 태그를 이용하여 소스 코드 구문 강조를 할 수 있습니다: <code>, <blockcode>, <apache>, <applescript>, <autoconf>, <awk>, <bash>, <c>, <cpp>, <css>, <diff>, <drupal5>, <drupal6>, <gdb>, <html>, <html5>, <java>, <javascript>, <ldif>, <lua>, <make>, <mysql>, <perl>, <perl6>, <php>, <pgsql>, <proftpd>, <python>, <reg>, <spec>, <ruby>. 지원하는 태그 형식: <foo>, [foo].
  • You can use Textile markup to format text.
  • 사용할 수 있는 HTML 태그: <p><div><span><br><a><em><strong><del><ins><b><i><u><s><pre><code><cite><blockquote><ul><ol><li><dl><dt><dd><table><tr><td><th><thead><tbody><h1><h2><h3><h4><h5><h6><img><embed><object><param><hr>

Markdown

  • 다음 태그를 이용하여 소스 코드 구문 강조를 할 수 있습니다: <code>, <blockcode>, <apache>, <applescript>, <autoconf>, <awk>, <bash>, <c>, <cpp>, <css>, <diff>, <drupal5>, <drupal6>, <gdb>, <html>, <html5>, <java>, <javascript>, <ldif>, <lua>, <make>, <mysql>, <perl>, <perl6>, <php>, <pgsql>, <proftpd>, <python>, <reg>, <spec>, <ruby>. 지원하는 태그 형식: <foo>, [foo].
  • Quick Tips:
    • Two or more spaces at a line's end = Line break
    • Double returns = Paragraph
    • *Single asterisks* or _single underscores_ = Emphasis
    • **Double** or __double__ = Strong
    • This is [a link](http://the.link.example.com "The optional title text")
    For complete details on the Markdown syntax, see the Markdown documentation and Markdown Extra documentation for tables, footnotes, and more.
  • web 주소와/이메일 주소를 클릭할 수 있는 링크로 자동으로 바꿉니다.
  • 사용할 수 있는 HTML 태그: <p><div><span><br><a><em><strong><del><ins><b><i><u><s><pre><code><cite><blockquote><ul><ol><li><dl><dt><dd><table><tr><td><th><thead><tbody><h1><h2><h3><h4><h5><h6><img><embed><object><param><hr>

Plain text

  • HTML 태그를 사용할 수 없습니다.
  • web 주소와/이메일 주소를 클릭할 수 있는 링크로 자동으로 바꿉니다.
  • 줄과 단락은 자동으로 분리됩니다.
댓글 첨부 파일
이 댓글에 이미지나 파일을 업로드 합니다.
파일 크기는 8 MB보다 작아야 합니다.
허용할 파일 형식: txt pdf doc xls gif jpg jpeg mp3 png rar zip.
CAPTCHA
이것은 자동으로 스팸을 올리는 것을 막기 위해서 제공됩니다.