thread pool사용시

전체 소스 입니다.

그리고 참고로 소스는 유닉스에서 컴파일해서 돌렸습니다.

#include <errno.h>
#include <fcntl.h>
#include <netinet/in.h>
#include <pthread.h>
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <sys/socket.h>
#include "socket_api.h"

#define LISTEN_BACK_LOG 10
#define LISTEN_PORT 9999
#define NUMBER_OF_THREADS 3
#define MAX 512
#define FILE_NAME_LEN 100

typedef struct thr_info {
pthread_t tid;
int client_fd;
int is_enabled;
} Threads;

Threads thread_pool[NUMBER_OF_THREADS];

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

void *processClientRequest(void *data)
{
int client_fd;
int file_fd;
pthread_t *tid = (pthread_t *)data;
int index;
int len, i;
int rt;
char filename[FILE_NAME_LEN+1];
char buffer[MAX+1];

printf("DEBUG[0] : processClientRequest(), tid[%d]\n", *tid);
for(index = 0; index < NUMBER_OF_THREADS; index++) {
if(thread_pool

.tid == *tid) {
printf("index [%d]...\n", index);
break;
}
}

for(;;) {

if(thread_pool

.is_enabled == 0) {

/* pthread_mutex_unlock(&mutex

); */
pthread_mutex_lock(&mutex

);
printf("DEBUG[1] : thread lock in threadfunction()...\n");
printf("DEBUG[2] : thread number [%d] is waiting for the signal here\n", index);
pthread_cond_wait(&cond

, &mutex

);
printf("DEBUG[8] : thread number [%d] start to work, enable[%d]!!!\n",
thread_pool

.is_enabled);
}

client_fd = thread_pool

.client_fd;
printf("DEBUG[9] : thread_pool[%d] is enabled, client_fd[%d]\n", index, client_fd);
memset(filename, 0x00, FILE_NAME_LEN+1);
memset(buffer, 0x00, MAX+1);

i = 0;
do {
rt = read(client_fd, &filename[i], 1);
if(rt < 0) {

if( (errno == EINTR) || (errno == EAGAIN) ) continue;
printf("read error\n");
return NULL;
}
if(rt == 0) {
printf("rt is now [%d]\n", rt);
break;
}

if(filename[i] == ' ') break;
i++;
} while(1);

filename[i] = '\0';

printf("DEBUG : filename [%s]\n", filename);

file_fd = open(filename, O_RDONLY);

if(file_fd == -1) {
printf("File Not Found...\n");
sprintf(buffer, "File Not Found...");
write(client_fd, buffer, strlen(buffer));
}
else {
printf("File Found...\n");
sprintf(buffer, "File Found...\n");
write(client_fd, buffer, strlen(buffer));

while((len = read(file_fd, buffer, MAX)) > 0) {
write(client_fd, buffer, len);
}
}

close(client_fd);
close(file_fd);
thread_pool

.is_enabled = 0;
printf("DEBUG[10] : thread_pool

.is_enabled = [%d]\n", thread_pool

.is_enabled);

pthread_mutex_unlock(&mutex

);
}

}

int initThreads()
{
int i, ret = 0;
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;

printf("initThreads_DEBUG : thread_pool[%d].tid = [%d], enabled [%d]\n",
i, thread_pool[i].tid, thread_pool[i].is_enabled);

ret = pthread_create(&thread_pool[i].tid, NULL,
processClientRequest,
&thread_pool[i].tid);
if(ret != 0) {
perror("pthread");
printf("ret [%d]\n", ret);
return 1;
}
printf("ret [%d]\n", ret);
}

return 0;
}

int main(int argc, char *argv[])
{
int server_fd;
int client_fd;
int len, i;
struct sockaddr_in addr;

setbuf(stdout, (char *)0);
server_fd = socket_server_init(LISTEN_PORT, LISTEN_BACK_LOG);
if(server_fd == -1) {
return 1;
}
printf("DEBUG : server_socket_fd = [%d]\n", server_fd);

if(initThreads() != 0) {
fprintf(stderr, "Cannot initialize threads...\n");
return 1;
}

for(;;) {

client_fd = accept(server_fd, (struct sockaddr *)&addr, &len);
if(client_fd == -1) {
perror("accept");
return 1;
}
printf("DEBUG[3] : accept...\n");

for(i = 0; i < NUMBER_OF_THREADS; i++) {
printf("DEBUG[4] : checking thread...\n");

if(thread_pool[i].is_enabled == 0) {
pthread_mutex_unlock(&mutex[i]);
pthread_mutex_lock(&mutex[i]);

thread_pool[i].client_fd = client_fd;
thread_pool[i].is_enabled = 1;
printf("DEBUG[5] : thread[%d] is now enabled[%d]...\n", i, thread_pool[i].is_enabled);

pthread_cond_signal(&cond[i]);
printf("DEBUG[6] : sigal has been sent...\n");

pthread_mutex_unlock(&mutex[i]);
printf("DEBUG[7] : mutex unlock in main()...\n");

break;
}
}

/* When we reach the maximum number of socket, we close client sd */
if(i == NUMBER_OF_THREADS) close(client_fd);
}

}

그리고 아래는 제가 찍은 로그입니다.

DEBUG[1] : thread lock in threadfunction()...
DEBUG[2] : thread number [0] is waiting for the signal here
DEBUG[3] : accept...
DEBUG[4] : checking thread...
DEBUG[5] : thread[0] is now enabled[1]...
DEBUG[6] : sigal has been sent...
DEBUG[7] : mutex unlock in main()...
DEBUG[8] : thread number [1] start to work, enable[-278243024]!!!
DEBUG[9] : thread_pool[0] is enabled, client_fd[5]
DEBUG : filename [Makefile]
File Found...
DEBUG[10] : thread_pool

.is_enabled = [0]

답변 감사합니다.