【Linux网络编程】基于TCP的线程池(pthread_pool)版本HTTP服务器
2017-06-01 17:50
537 查看
(线程池代码参考网上的)
服务器代码:
线程池代码:
服务器代码:
#include <stdio.h> #include <stdlib.h> #include <string.h> #include <pthread.h> #include <sys/socket.h> #include <netinet/in.h> #include <arpa/inet.h> #include "mypthreadpool.h" #define SOCK_FAIL 1 #define BIND_FAIL 2 #define LISTEN_FAIL 3 #define USE_ERROR 4 #define ACCPET_FAIL 5 int amount = 0; // 使用说明 static void Usage(const char* arg) { printf("Usage:%s [server_ip] [server_port]\n", arg); } int startup(const char* ip, int port) { // 1. new socket int sock = socket(AF_INET, SOCK_STREAM, 0 ); if(sock < 0) { perror("socket ---"); exit(SOCK_FAIL); } // 2. bind socket struct sockaddr_in local; local.sin_family = AF_INET; local.sin_addr.s_addr = inet_addr(ip); local.sin_port = htons(port); int opt = 1; setsockopt(sock, SOL_SOCKET, SO_REUSEADDR, &opt, sizeof(opt)); if( bind(sock, (struct sockaddr*)&local, sizeof(local)) < 0) { perror("bind ---"); exit(BIND_FAIL); } // 3. listen socket if( listen(sock, 5) < 0) { perror("listen ---"); exit(LISTEN_FAIL); } return sock; } void* handler(void *arg) { int sock = (int)arg; char buf[10240]; while(1) { ssize_t s = read(sock, buf, sizeof(buf)-1); if(s < 0) { perror("Read"); exit(-1); } else if (s > 0) { const char* msg = "HTTP/1.1 200 OK\r\n\r\n<html><h1>This is title</h1></html>\r\n"; buf[s] = '\0'; printf("- message: %s \n", buf); write(sock, msg, strlen(msg)); break; } else break; } printf("quit\n"); } int main(int argc, char* argv[]) { pool_init(3); // 线程池中最多三个活动线程 if(argc != 3) { Usage(argv[0]); return USE_ERROR; } int listen_sock = startup(argv[1], atoi(argv[2])); // ip port struct sockaddr_in peer; socklen_t len = sizeof(peer); printf("listen .... \n"); while(1) { int new_sock = accept(listen_sock, (struct sockaddr*)&peer, &len); if( new_sock < 0) { perror("accept --- "); continue; } printf("connect sucess ! client : ip %s prot %d \n", inet_ntoa(peer.sin_addr), ntohs(peer.sin_port)); pool_add_worker(handler, (void*)new_sock); } return 0; }
线程池代码:
#include <stdio.h> #include <stdlib.h> #include <unistd.h> #include <sys/types.h> #include <pthread.h> #include <assert.h> /* *线程池里所有运行和等待的任务都是一个CThread_worker *由于所有任务都在链表里,所以是一个链表结构 */ typedef struct worker { /*回调函数,任务运行时会调用此函数,注意也可声明成其它形式*/ void *(*process) (void *arg); void *arg;/*回调函数的参数*/ struct worker *next; } CThread_worker; /*线程池结构*/ typedef struct { pthread_mutex_t queue_lock; pthread_cond_t queue_ready; /*链表结构,线程池中所有等待任务*/ CThread_worker *queue_head; /*是否销毁线程池*/ int shutdown; pthread_t *threadid; /*线程池中允许的活动线程数目*/ int max_thread_num; /*当前等待队列的任务数目*/ int cur_queue_size; } CThread_pool; int pool_add_worker (void *(*process) (void *arg), void *arg); void *thread_routine (void *arg); static CThread_pool *pool = NULL; void pool_init (int max_thread_num) { pool = (CThread_pool *) malloc (sizeof (CThread_pool)); pthread_mutex_init (&(pool->queue_lock), NULL); pthread_cond_init (&(pool->queue_ready), NULL); pool->queue_head = NULL; pool->max_thread_num = max_thread_num; pool->cur_queue_size = 0; pool->shutdown = 0; pool->threadid = (pthread_t *) malloc (max_thread_num * sizeof (pthread_t)); int i = 0; for (i = 0; i < max_thread_num; i++) { pthread_create (&(pool->threadid[i]), NULL, thread_routine, NULL); } } /*向线程池中加入任务*/ int pool_add_worker (void *(*process) (void *arg), void *arg) { /*构造一个新任务*/ CThread_worker *newworker = (CThread_worker *) malloc (sizeof (CThread_worker)); newworker->process = process; newworker->arg = arg; newworker->next = NULL;/*别忘置空*/ pthread_mutex_lock (&(pool->queue_lock)); /*将任务加入到等待队列中*/ CThread_worker *member = pool->queue_head; if (member != NULL) { while (member->next != NULL) member = member->next; member->next = newworker; } else { pool->queue_head = newworker; } assert (pool->queue_head != NULL); pool->cur_queue_size++; pthread_mutex_unlock (&(pool->queue_lock)); /*好了,等待队列中有任务了,唤醒一个等待线程; 注意如果所有线程都在忙碌,这句没有任何作用*/ pthread_cond_signal (&(pool->queue_ready)); return 0; } /*销毁线程池,等待队列中的任务不会再被执行,但是正在运行的线程会一直 把任务运行完后再退出*/ int pool_destroy () { if (pool->shutdown) return -1;/*防止两次调用*/ pool->shutdown = 1; /*唤醒所有等待线程,线程池要销毁了*/ pthread_cond_broadcast (&(pool->queue_ready)); /*阻塞等待线程退出,否则就成僵尸了*/ int i; for (i = 0; i < pool->max_thread_num; i++) pthread_join (pool->threadid[i], NULL); free (pool->threadid); /*销毁等待队列*/ CThread_worker *head = NULL; while (pool->queue_head != NULL) { head = pool->queue_head; pool->queue_head = pool->queue_head->next; free (head); } /*条件变量和互斥量也别忘了销毁*/ pthread_mutex_destroy(&(pool->queue_lock)); pthread_cond_destroy(&(pool->queue_ready)); free (pool); /*销毁后指针置空是个好习惯*/ pool=NULL; return 0; } void * thread_routine (void *arg) { //printf ("starting thread 0x%x/n", pthread_self ()); while (1) { pthread_mutex_lock (&(pool->queue_lock)); /*如果等待队列为0并且不销毁线程池,则处于阻塞状态; 注意 pthread_cond_wait是一个原子操作,等待前会解锁,唤醒后会加锁*/ while (pool->cur_queue_size == 0 && !pool->shutdown) { printf ("thread 0x%x is waiting/n", pthread_self ()); pthread_cond_wait (&(pool->queue_ready), &(pool->queue_lock)); } /*线程池要销毁了*/ if (pool->shutdown) { /*遇到break,continue,return等跳转语句,千万不要忘记先解锁*/ pthread_mutex_unlock (&(pool->queue_lock)); printf ("thread 0x%x will exit/n", pthread_self ()); pthread_exit (NULL); } printf ("thread 0x%x is starting to work/n", pthread_self ()); /*assert是调试的好帮手*/ assert (pool->cur_queue_size != 0); assert (pool->queue_head != NULL); /*等待队列长度减去1,并取出链表中的头元素*/ pool->cur_queue_size--; CThread_worker *worker = pool->queue_head; pool->queue_head = worker->next; pthread_mutex_unlock (&(pool->queue_lock)); /*调用回调函数,执行任务*/ (*(worker->process)) (worker->arg); free (worker); worker = NULL; } /*这一句应该是不可达的*/ pthread_exit (NULL); }
相关文章推荐
- 【Linux网络编程】基于TCP的多线程(pthread)版本最简陋的HTTP服务器
- 【Linux网络编程】基于TCP单进程版本阻塞式客户端/服务器
- 【Linux网络编程】基于TCP多进程(fork)版本客户端/服务器
- Linux网络编程:基于TCP的程序开发回顾篇
- 基于Linux的TCP网络编程
- 基于TCP的服务器端/客户端(一)---------网络编程(linux----C)
- Linux网络编程:基于TCP的程序开发回顾篇
- Linux网络编程:基于TCP的程序开发回顾篇
- 基于Linux的TCP网络编程
- Linux下TCP网络编程与基于Windows下C#Socket编程间通信
- 基于TCP的服务器端/客户端(二)---------网络编程(Linux----C)
- Linux网络编程:基于TCP的程序开发回顾篇《转》
- linux socket网络编程二 基于tcp
- 【Linux网络编程】基于TCP流 I/O多路转接(poll) 的高性能http服务器
- Linux网络编程:基于TCP的程序开发回顾篇
- Linux网络编程【三】:TCP服务器多进程和多线程(http访问)版本
- Linux网络编程:基于TCP的程序开发回顾篇
- Linux网络编程:基于TCP的程序开发
- 基于Linux的TCP网络编程
- 基于Linux的TCP网络编程